怎样一个角色串联的列在Java的Apache的火花值
我想获得一个特定的列的值表示costs
作为怎样一个角色串联的列在Java的Apache的火花值
spark.select(col("col1"), col("col2"), col("costs")) .groupBy("col1")
.agg(sum(col("costs")));
输出应该具有的附加列成本数据与$
符号。
回答:
您需要使用和concat
组合lit
spark.select(col("col1"), col("col2"), col("costs")) .groupBy("col1")
.agg(sum(col("costs")).as("costs"))
.withColumn("costs" , concat(lit("$") , col("costs"))) ;
以上是 怎样一个角色串联的列在Java的Apache的火花值 的全部内容, 来源链接: utcz.com/qa/265636.html