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 >
