抱歉,這可能是非常明顯的事情。我不明白為什么這不起作用:
val df = spark.createDataFrame([("A",1),("B",2),("C",3)],["Letter","Number"])
當我運行它時,我收到以下錯誤:
錯誤:簡單運算式的非法開始
為什么這不起作用?
uj5u.com熱心網友回復:
這是 Pyspark 語法而不是 Spark Scala。試試這個:
val df = spark.createDataFrame(Seq(("A",1),("B",2),("C",3))).toDF("Letter", "Number")
或者:
import spark.implicits._
val df = Seq(("A",1),("B",2),("C",3)).toDF("Letter", "Number")
轉載請註明出處,本文鏈接:https://www.uj5u.com/qianduan/405128.html
標籤:
