如何與火花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));