Mutable objects in Flink ?

[Hajira Jabeen]

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

[Stephan Ewen]

Hi!

Sorry, I do not really understand you question. Can you paste the skeleton of your program code here?

Thanks,

Stephan

On Fri, Nov 6, 2015 at 6:55 PM, Hajira Jabeen <[hidden email]> wrote:

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