为了在$"my_column"中使用spark sql结构,我们需要:
import spark.implicits._然而,这并不能在jupyter笔记本单元中工作:结果是:
Name: Compile Error
Message: <console>:49: error: stable identifier required, but this.$line7$read.spark.implicits found.
import spark.implicits._
^我以前见过笔记本,但它们可能是zeppelin.有办法给jupyter买这个吗?
发布于 2018-03-22 20:25:55
这里有一个可以工作的黑客。
val spark2: SparkSession = spark
import spark2.implicits._因此,现在spark2的引用显然是“稳定的”。
https://stackoverflow.com/questions/49436770
复制相似问题