怎样一个角色串联的列在Java的Apache的火花值

Question

我想获得一个特定的列的值表示costs 作为

spark.select(col("col1"), col("col2"), col("costs")) 
    .groupBy("col1") 
    .agg(sum(col("costs"))); 

输出应该具有的附加列成本数据与$符号。

Answer 1

您需要使用和concat组合lit

spark.select(col("col1"), col("col2"), col("costs")) 
    .groupBy("col1") 
    .agg(sum(col("costs")).as("costs")) 
    .withColumn("costs" , concat(lit("$") , col("costs"))) ;