Scala - 为什么函数返回Unit而不是RDD? [重复]

问题描述 投票:-1回答:1

这个问题在这里已有答案:

当我实现该功能时,我希望它返回一个RDD。并可能稍后将其收集到List。但为什么它会返回Unit呢?我应该在实现中更改什么才能使其返回RDD?

销售是一张地图(saleId,Saletype) - val sales: Map[Int, String]

val processSales: Unit = sales.foreach(sale => sc.makeRDD(salesService.getData(sale._1)))
scala apache-spark rdd
1个回答
2
投票

foreach返回Unit,您可以看到返回类型如下

def foreach(f:T => Unit):单位=

使用map代替返回RDD

def map [U:ClassTag](f:T => U):RDD [U] =

© www.soinside.com 2019 - 2024. All rights reserved.