如何使用一些靜態值在DataFrame中添加列？

Question

我有一個Spark SQL DataFrame與幾列，但我想添加一些靜態值的DataFrame中更多的列。我怎樣才能做到這一點？

我試過withColumn方法，但其預計Column

所預期的那樣：

df.withColumn(col("newColumn", "static value") 

更新：

我得到了答案，我們需要使用​​3210用於此目的。

例如：

df.withColumn("newColumn", lit("some value") 

Answer 1

你可以把它簡單地使用UDF這樣你就可以定義UDF其返回默認值，然後添加列並設置爲默認值如下

val defaultValue=spark.udf.register("defaultValue",()=>"default") 

df.withColumn(col("newColumn", defaultValue) 

df.show() 

創建