Làm thế nào để thêm cột với liên tục trong khung dữ liệu Spark-java

Question

tôi đã nhập khẩu

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

trong trình điều khiển Java-Spark tôi

Nhưng

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

here "thắp sáng" là vẫn hiển thị lỗi trong nhật thực (cửa sổ). Tôi nên đưa thư viện vào để làm cho nó hoạt động.

Answer 1

Hoặc đối tượng nhập khẩu như bạn biết và sử dụng nó để truy cập phương pháp:

import org.apache.spark.sql.functions; 

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

hoặc sử dụng import static và gọi phương thức trực tiếp:

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

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