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].

Best,
Martin

[1]
https://github.com/apache/flink/blob/master/flink-java/src/main/java/org/apache/flink/api/java/utils/DataSetUtils.java#L131

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
> 

Mime
View raw message