将java转换为scala代码

Question

将 java 转换为 scala 代码我遇到了一个奇怪的问题 一个例子可以在这里找到https://gist.github.com/geoHeil/895260a04d3673b9848b345edf388a2d 错误是

[error] src/main/scala/myOrg/CustomInputMapperWKT.scala:17: overriding method call in trait FlatMapFunction of type (x$1: String)java.util.Iterator[Any];
[error]  method call has incompatible type
[error]   override def call(line: String): Iterator[_] = {

尝试将 spark java 转换为 spark scala API 时 我正在努力将这个 java 类 https://github.com/DataSystemsLab/GeoSpark/blob/master/src/main/java/org/datasyslab/geospark/showcase/UserSuppliedPolygonMapper.java#L59-L81 移植到 scala。

在哪里

class CustomInputMapperWKT extends FlatMapFunction[String, Any] {
....
override def call(line: String): Iterator[_] = {
val result: collection.Seq[Polygon] with Growable[Polygon] = mutable.Buffer[Polygon]()
result.iterator
  }
}

是描述问题的最小样本。

编辑

为了解决可能的打字问题，我将 Any 替换为相应的多边形类型。 但这无助于解决问题。

Answer 1

你试过这个签名吗？

override def call(t: String): java.util.Iterator[Any] = {
...

因为这个代码示例编译成功：

import org.apache.spark.api.java.function.FlatMapFunction
import collection.JavaConverters._

class CustomInputMapperWKT extends FlatMapFunction[String, Any] {
  override def call(t: String): java.util.Iterator[Any] = {
    ...
    result.iterator.asJava
  }
}