DATAFRAME方法

Question

I持って、次のエラーで SBT に火花シェル

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

に動作しますが、失敗し、次のコード：

not found: value split 
not found: value explode 

マイScalaのコード

sbt環境で、誰かが私に何が間違っているかのポインタを教えてもらえますか？

おかげ

Answer 1

スプリットと爆発する機能は、パッケージfunctions内部org.apache.spark.sqlでご利用いただけます。

だから、両方

​​

それとも

org.apache.spark.sql.functions._ 

は、この情報がお役に立てば幸いインポートする必要があります！