spark java如何使用withcolumn选择新添加的列

Question

我正在尝试创建java spark程序，并尝试使用

qdf.withColumn("newColumn", functions.lit("newCOlumn_val"))

当我试图选择

qdf.withColumn("newColumn", functions.lit("newColumn_val")).select(qdf.col("xyz"),qdf.col("newColumn")).show();

它说不能再爱列名newColumn了。有人能帮我用Java怎么做吗？

Answer 1

试试下面的代码。

qdf.withColumn("newColumn", functions.lit("newColumn_val"))
.select("xyz","newColumn")
.show();