是`dataframe.write.mode(savemode.overwrite)text(output)`有效的scala/spark sql语法吗?

mfpqipee  于 2021-05-27  发布在  Spark
关注(0)|答案(1)|浏览(473)

所以我有一个拼写错误 dataframe.write.mode(SaveMode.Overwrite)text(output) 缺少一段时间 mode 以及 text ,但eclipse似乎没有抱怨,当我在junit和产品中运行它时,一切似乎无一例外地运行良好,甚至产生了正确的输出。我很困惑没有任何bug,我的spark dag确实显示我的代码已经更改,所以我更困惑。有什么想法吗?

zzzyeukh

zzzyeukh1#

这就是scala的工作方式。是中缀符号
由于括号的原因,不需要空格。下面是一个演示:

scala> val l = List(1,2,3)
l: List[Int] = List(1, 2, 3)

scala> l.take(1)
res4: List[Int] = List(1)

scala> l take 1
res5: List[Int] = List(1)

scala> (l)take 1
res6: List[Int] = List(1)

scala> l.take(2)take(1)
res7: List[Int] = List(1)

相关问题