时间戳

首页 > 解决方案 > Scala - 为什么函数返回 Unit 而不是 RDD？

scala - Scala - 为什么函数返回 Unit 而不是 RDD？

问题描述

当我实现了这个函数时，我希望它返回一个 RDD。并且可能稍后将其收集到列表中。但是为什么它会返回 Unit 呢？我应该在实现中进行哪些更改以使其返回 RDD？

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

val processSales: Unit = sales.foreach(sale => sc.makeRDD(salesService.getData(sale._1)))

标签： scalaapache-sparkrdd

解决方案

foreachreturn , 你可以看到返回Unit类型如下

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

map改为使用返回RDD

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

推荐阅读