I think for that you would unpack to List of values, for example with a FlatMap<List<T>, T>. This would emit each element of the list as a separate element. Then, downstream operations can operate on each element individually and you will exploit parallelism in the cluster.
Best, Aljoscha > On 13. Jun 2017, at 10:49, nragon <nuno.goncal...@wedotechnologies.com> wrote: > > Iterate until all elements were changed perhaps. But just wanted to know if > there areimplementations out there using java 8 streams, in cases where you > want to parallelize a map function even if it is function scoped. > So, in my case, if the computation for each list element is to heavy, how > can one parallelize it? > > > > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Java-parallel-streams-vs-IterativeStream-tp13655p13677.html > Sent from the Apache Flink User Mailing List archive. mailing list archive at > Nabble.com.
