我有一个用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(???))