Я написал метод в 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(???))