简单表达式的非法开始在 spark 中创建一个简单的数据框

Question

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

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

当我运行出现以下错误时：

error: illegal start of simple expression

为什么这不起作用？

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

Illegal start of simple expression creating a simple dataframe in spark