我在 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(???))
最佳答案
关于java - 如何将 Scala Iterable 转换为 Java util.List?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/52745824/