score:2

Accepted answer

have you tried this signature?

override def call(t: string): java.util.iterator[any] = {
...

because this code example is compiled successfully:

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
  }
}

Related Query

More Query from same tag