значение кода искры скала внутри карты - PullRequest
0 голосов
/ 28 июня 2018
Scala> val custdata = sc.textFile("file:///stage/Sales/lego/test/new/spark_test/testing1.csv")
custdata: org.apache.spark.rdd.RDD[String] = file:///stage/Sales/lego/test/new/spark_test/testing1.csv MapPartitionsRDD[8] at textFile at <console>:27

scala> custdata.collect
res3: Array[String] = Array(1,111,1000, 1,222,2000, 2,222,15000, 3,111,4500, 4,333,1200, 2,333,1000, 4,444,2000)

scala> val data= custdata.map(x=> { val b = x.split(",")})
data: org.apache.spark.rdd.RDD[Unit] = MapPartitionsRDD[9] at map at <console>:29

scala> data.collect
res4: Array[Unit] = Array((), (), (), (), (), (), ())

Искра scala сомнения: Из-за val b Я не могу получить результат? ребята, не могли бы вы помочь мне с этим

1 Ответ

0 голосов
/ 28 июня 2018

Вы не возвращаете никакого значения в custdata.map(x=> { val b = x.split(",")}), если вы просто хотите вернуть b, вы можете заменить на custdata.map(x=> { val b = x.split(",");b}) или custdata.map(x=> { x.split(",")}) или даже лучше (как правильно заметил @joelb в комментарии) custdata.map(_.split(","))

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...