flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Filip Łęczycki <filipleczy...@gmail.com>
Subject Re: Problems with using ZipWithIndex
Date Sat, 12 Dec 2015 19:48:55 GMT
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.marton@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 <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