स्पार्क जावा डेटा फ्रेम में लगातार

Question

मैं अपने जावा-स्पार्क ड्राइवर में

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")); 

यहाँ

"जलाया" अभी भी दिखाई दे रहा है के साथ स्तंभ जोड़ने के लिए कैसे ग्रहण (विंडोज़) में त्रुटि। मुझे किस पुस्तकालय को इसे काम करने के लिए शामिल करना चाहिए।

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));