如何转换斯卡拉可迭代到Java util.List?

问题描述 投票:1回答:1

我有一个用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 apache-spark collections
1个回答
2
投票
a.toSeq.asJava

需要注意的是,如果这Iterable实际上是一个SeqtoSeq刚刚返回相同的对象。

API doc对于转换的完整列表。

© www.soinside.com 2019 - 2024. All rights reserved.