Jak dodać kolumnę stała w ramce danych Spark-java

Question

mam importowane

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

w moim kierowcą Java-Spark

Ale

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

tutaj "świeci" jest nadal wykazujące błąd w eclipse (Windows). Którą bibliotekę powinienem dołączyć, aby działało.

Answer 1

Albo obiekt import jak ty wiem i używać go w celu uzyskania dostępu metoda:

import org.apache.spark.sql.functions; 

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

lub użyj import static i wywołanie metody bezpośrednio:

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

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