flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Till Rohrmann <trohrm...@apache.org>
Subject Re: Parallelizing DataStream operations on Array elements
Date Mon, 07 Nov 2016 13:57:55 GMT
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 <dsuo@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.
>

Mime
View raw message