在spark中创建简单数据帧的简单表达式的非法启动

Question

抱歉，这可能是非常明显的事情。我不明白为什么这不起作用：

val df = spark.createDataFrame([("A",1),("B",2),("C",3)],["Letter","Number"])

当我运行这个时，我得到以下错误：

错误：非法启动简单表达式

为什么不起作用？

Answer 1

这是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")