这个问题在这里已有答案:
当我实现该功能时,我希望它返回一个RDD。并可能稍后将其收集到List。但为什么它会返回Unit呢?我应该在实现中更改什么才能使其返回RDD?
销售是一张地图(saleId,Saletype) - val sales: Map[Int, String]
val processSales: Unit = sales.foreach(sale => sc.makeRDD(salesService.getData(sale._1)))
foreach
返回Unit
,您可以看到返回类型如下
def foreach(f:T => Unit):单位=
使用map
代替返回RDD
def map [U:ClassTag](f:T => U):RDD [U] =