Spark Java API：为DataSet列拼接$值的实现方法咨询

这事儿很简单，用Spark的concat()函数就能轻松实现，直接把原列的值和字符串" $"拼接起来即可。下面是具体的Java代码实现：

1. 先导入需要的Spark函数 #

import static org.apache.spark.sql.functions.concat;
import static org.apache.spark.sql.functions.lit;
import org.apache.spark.sql.Column;

2. 处理DataSet，为指定列拼接$ #

假设你的原始DataSet对象名为df，执行以下代码就能得到你想要的结果：

Dataset<Row> resultDf = df
    // 为C1列拼接" $"，覆盖原列
    .withColumn("C1", concat(col("C1"), lit(" $")))
    // 为C2列拼接" $"，覆盖原列
    .withColumn("C2", concat(col("C2"), lit(" $")));

小说明： #

• concat()：Spark提供的字符串拼接函数，支持多个字符串/列的拼接操作；
• lit(" $")：创建一个常量字符串列，值为" $"（注意$前面有个空格，和你期望的结果格式一致）；
• 如果不想覆盖原列，只想生成带$的新列，只需要把withColumn的第一个参数改成新列名就行，比如.withColumn("C1_new", concat(col("C1"), lit(" $")))。

内容的提问来源于stack exchange，提问作者OOvic