scala更改datafream数据

要更改 Spark DataFrame 中的数据，您可以使用以下方法之一：

1. 使用 withColumn() 方法：该方法允许您添加新列或替换现有列的值。例如，如果您要将一列中的所有值乘以 2 并将结果存储在新列中，可以执行以下操作：

   val df2 = df.withColumn("new_col", df("old_col") * 2)

2. 使用 select() 方法：该方法允许您选择要保留的列以及对这些列进行转换。例如，如果您只想保留一列并将其值加 1，可以执行以下操作：

   val df2 = df.select(df("col_name") + 1)

3. 使用 map() 方法：该方法允许您在 RDD 上应用自定义函数。您可以将 DataFrame 转换为 RDD，然后使用 map() 方法更改数据。例如，如果您要将一列中的所有值转换为小写，可以执行以下操作：

   val rdd = df.rdd.map(row => Row(row.getString(0).toLowerCase))
   val df2 = spark.createDataFrame(rdd, df.schema)