In order to parallelize by voxel you have to do a keyBy(rowId) given that rowId is the same as voxel id.
Glad to hear that you’ve resolved the problem :-) Cheers, Till On Sat, Nov 5, 2016 at 2:47 AM, danielsuo <d...@cs.princeton.edu> wrote: > I was able to resolve my issue by collecting all the 'column' Arrays via > countWindowAll and using flatMap to emit 'row' Arrays. > > > > -- > View this message in context: http://apache-flink-user- > mailing-list-archive.2336050.n4.nabble.com/Parallelizing- > DataStream-operations-on-Array-elements-tp9911p9917.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >
