【发布时间】:2019-03-15 16:41:50
【问题描述】:
我在 Scala 中编写了一个使用 Java 编写的方法的方法 - processSale() 方法将 util.List<Sale> 作为参数。
但在groupByKey() 之后,我得到了RDD[(String, Iterable[Sale])]。我尝试导入scala.collection.JavaConverters._ 并执行SaleParser.processSale(a.asJava)。
但是它给了我一个Iterable[Sale]。怎么可能转换成Javautil.List?
val parseSales: RDD[(String, Sale)] = rawSales
.map(sale => sale.Id -> sale)
.groupByKey()
.mapValues(a => SaleParser.processSale(???))
【问题讨论】:
标签: java scala apache-spark collections