flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Hajira Jabeen <hajirajab...@gmail.com>
Subject Mutable objects in Flink ?
Date Fri, 06 Nov 2015 17:55:43 GMT
Hi all,

I am writing an evolutionary computing application with Flink.
Each object is a particle with multidimensional velocity , position, and
fitness.
I create a population ( Array) of these objects and want to update
positions and velocities of all particles in parallel.

I can create the population as a data set.
Apparently, I can also apply Move () , Update() as Map functions .

But in actual the values( positions, velocities, fitness) are not updated .

Any comments ?

Regards

Hajira

Mime
View raw message