flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Stephan Ewen <se...@apache.org>
Subject Re: Mutable objects in Flink ?
Date Sat, 07 Nov 2015 21:02:30 GMT
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 <hajirajabeen@gmail.com>
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
>
>
>

Mime
View raw message