我有一个用Scala编写的方法,它使用一个用Java编写的方法-- processSale()
方法以util.List<Sale>
作为参数。
但在groupByKey()
之后,我得到了一个RDD[(String, Iterable[Sale])]
。我试着导入scala.collection.JavaConverters._
和做SaleParser.processSale(a.asJava)
。
然而,它给了我一个Iterable[Sale]
。如何将其转换为Java util.List
val parseSales: RDD[(String, Sale)] = rawSales
.map(sale => sale.Id -> sale)
.groupByKey()
.mapValues(a => SaleParser.processSale(???))
发布于 2018-10-11 01:40:41
https://stackoverflow.com/questions/52745824
复制相似问题