> val orders = sc.textFile("file:///Users/jzhang/Downloads/SampleData.csv")
> .map{line=>line.split(",")}
The above code won't compile successfully, raise error
> orders: org.apache.spark.rdd.RDD[String] = MapPartitionsRDD[51] at
textFile at> <console>:39 > <console>:1: error: illegal start of definition
.map{line=>line.split(",")}
I only have to write it as following to make it pass the compilation.
> val orders =
sc.textFile("file:///Users/jzhang/Downloads/SampleData.csv").map{
> line=>line.split(",")}
I am not sure why. Is it intended or difficult to make it compatible with
scala syntax ?
BTW, I am using zeppelin 0.5
--
Best Regards
Jeff Zhang
