Sorry, I didn't see the pathID which is added in the map() method. Then your approach looks good for using Flink locally.
On Fri, Feb 6, 2015 at 3:03 PM, Nam-Luc Tran <namluc.t...@euranova.eu> wrote: > Thank you for your replies. > > @Stephen > Updating to 0.9-SNAPSHOT and using the "return" statement did the trick. I > will try the 4.5 M4 release and give a feedback on how it went. > > @Robert > I launch the job right from the Eclipse IDE. > Also, each file in the folder contains data for a different trajectory. By > iterating this way I create a different dataset for each trajectory and add > a tag for identifying data of a same trajectory. I then union all these > datasets together in a same dataset. Do you see a more streamlined way to > achieve this? > > Best regards, > > Tran Nam-Luc > > > > > -- > View this message in context: > http://apache-flink-incubator-mailing-list-archive.1008284.n3.nabble.com/Eclipse-JDT-Java-8-lambdas-tp3664p3675.html > Sent from the Apache Flink (Incubator) Mailing List archive. mailing list > archive at Nabble.com. >
