怎样一个角色串联的列在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

回到顶部