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
