如何与火花Java数据帧不断

Question

我在Java的星火驱动进口

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

但

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

这里“上火”仍显示出添加列eclipse中的错误（windows）。我应该包含哪个库才能使它工作。

Answer 1

无论是进口对象就像你知道的，并用它来访问方法：

import org.apache.spark.sql.functions; 

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

或使用import static并直接调用方法：

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

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