通过向spark dtaframe column添加值来生成一个新列

arknldoa  于 2021-05-29  发布在  Hadoop
关注(0)|答案(1)|浏览(610)

关闭。这个问题需要更加突出重点。它目前不接受答案。
**想改进这个问题吗?**通过编辑这篇文章更新这个问题,使它只关注一个问题。

两年前关门了。
改进这个问题
我在sparkDataframe中有一列,它是整数。如何使用sparkjava为列中的每个值添加一个新列

eufgjt7s

eufgjt7s1#

可以使用df.withcolumn将新列添加到Dataframe。

import static org.apache.spark.sql.functions.col;
DataFrame df2 = df1.withColumn("new_column", col("column_name").plus(1));

相关问题