flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Márton Balassi <balassi.mar...@gmail.com>
Subject Re: Problems with using ZipWithIndex
Date Sat, 12 Dec 2015 18:56:08 GMT
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, Filip Łęczycki <filipleczycki@gmail.com>
wrote:

> 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 org.apache.flink.api.scala.DataSet
> and there is no such function. I am using the latest version, 0.10.1. Was
> it removed or moved to different module? Is there any way to use it?
>
> When i try to use the function from DataSetUtils java module:
>
> data is of type DataSet[AlignmentRecord]
> val indexed = DataSetUtils.zipWithIndex[AlignmentRecord](data)
>
> I receive following error:
> Type mismatch: expected: DataSet[AlignmentRecord], actual:
> DataSet[AlignmentRecord]
>
> Could you please guide me how to use this function?
>
> Pozdrawiam,
> Filip Łęczycki
>

Mime
View raw message