I just tested the zipWithIndex method with Flink 0.10.1 and it worked. I
used the following code:
import org.apache.flink.api.scala._
import org.apache.flink.api.scala.utils._
object Job {
def main(args: Array[String]): Unit = {
val env = ExecutionEnvironment.getExecutionEnvironment
v
Hi Marton,
Thank you for your answer. I wasn't able to use zipWithIndex in a way that
you stated as i got "cannot resolve" error. However it worked when i used
it like this:
val utils = new DataSetUtils[AlignmentRecord](data)
val index = utils.zipWithIndex
Regards,
Filip Łęczycki
Pozdra
Hey Filip,
As you are using the scala API it is easier to use the Scala DataSet utils,
which are accessible after the following import:
import org.apache.flink.api.scala.utils._
Then you can do the following:
val indexed = data.zipWithIndex
Best,
Marton
On Sat, Dec 12, 2015 at 7:48 PM, Fili
Hi all,
I tried to use ZipWithIndex functionality, accordingly to the Scala
examples posted here:
https://ci.apache.org/projects/flink/flink-docs-master/apis/zip_elements_guide.html
however I am not able to call the mentioned function because it cannot be
resolved. I checked the flink code for or
