当我尝试创建名称为 "org" 的变量时,为什么会出现火花壳抛出错误?



我试图在火花外壳(Scala 版本 2.10.5(中创建名为"org"的变量/val,但抛出错误

我尝试了 var 和 val。

 var org = List(1)

错误:值 apache 不是 List[Int] 的成员 org.apache.spark.sql.catalyst.encoders.OuterScopes.addOuterScope(this(

好吧,我能够创建名为"org"的列表、数据帧

scala> val org = List(1)
org: List[Int] = List(1)
scala> var org = List(1)
org: List[Int] = List(1)
scala>
scala>
scala> val org = Seq((1,2,3), (2,3,4)).toDF()
org: org.apache.spark.sql.DataFrame = [_1: int, _2: int ... 1 more field]
scala> org
res0: org.apache.spark.sql.DataFrame = [_1: int, _2: int ... 1 more field]
scala> org.show
+---+---+---+
| _1| _2| _3|
+---+---+---+
|  1|  2|  3|
|  2|  3|  4|
+---+---+---+

我正在使用Spark版本2.2.0和scala 2.11.8。我认为这个问题可能会在最新版本中得到纠正。但我知道你不能使用一些保留的关键字创建值或变量。例如

scala> val new = Seq((1,2)(2,3)).toDF()
<console>:1: error: illegal start of simple pattern
val new = Seq((1,2)(2,3)).toDF()

"org"可能是以前版本中的关键字。希望有帮助...!!

相关内容

  • 没有找到相关文章

最新更新