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
Pozdrawiam,
Filip Łęczycki
2015-12-12 19:56 GMT+01:00 Márton Balassi <balassi.mar...@gmail.com>:
> 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 <filipleczy...@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
>>
>
>
