如何在Spark-java数据框中添加常量列

Question

我已经导入了

import org.apache.spark.sql.Column;
import org.apache.spark.sql.functions;

在我的Java-Spark驱动中

但

DataFrame inputDFTwo = hiveContext.sql("select * from sourcing_src_tbl");
inputDFTwo.withColumn("asofdate", lit("2016-10-2"));

这里"lit“仍然在eclipse(windows).Which库中显示错误，我应该将它包含进来才能正常工作。

Answer 1

或者像您所知道的那样导入对象，并使用它来访问方法：

import org.apache.spark.sql.functions;

df.withColumn("foo", functions.lit(1));

或者直接使用import static和call方法：

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

df.withColumn("foo", lit(1));