flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Martin Junghanns <m.jungha...@mailbox.org>
Subject Re: Long ids from String
Date Tue, 03 Nov 2015 08:59:51 GMT
Hi Flavio,

If you just want to assign a unique Long identifier to each element in
your dataset, you can use the DataSetUtils.zipWithUniqueId() method [1].



On 03.11.2015 09:42, Flavio Pompermaier wrote:
> Hi to all,
> I was reading the thread about the Neo4j connector and an old question came
> to my mind.
> In my Flink job I have Tuples with String ids that I use to join on that
> I'd like to convert to long (because Flink should improve quite a lot the
> memory usage and the processing time if I'm not wrong).
> Is there any recommended way to do that conversion in Flink?
> Best,
> Flavio

View raw message