數據幀的方法

Question

我有下面的代碼與下面的錯誤在火花外殼

df1.withColumn("tags_splitted", split($"tags", ",")).withColumn("tag_exploded", explode($"tags_splitted")).select("id", "tag_exploded").show() 

的作品，但未能在SBT：

not found: value split 
not found: value explode 

我的Scala代碼有以下幾種

import org.apache.spark.sql.SparkSession 
val spark = SparkSession.builder().appName("Books").getOrCreate() 
import spark.implicits._ 

有人能給我一個指針，指出環境中有什麼問題嗎？

由於

Answer 1

分割和爆炸功能在包org.apache.spark.sql內部functions是可用的。

因此，您需要同時導入

​​

或者

org.apache.spark.sql.functions._ 

希望這有助於！