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 wrote:
> I was able to resolve my issue by collecting all the 'column' Arrays via
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.
Till Rohrmann wrote
> I'm not sure whether I grasp the whole problem, but can't you split
> thevector up into the different rows, group by the row index and then
> applysome kind of continuous aggregation or window function?
So I could flatMap my incoming Arrays into (rowId, arrayElement) and gath
Hi Daniel,
I'm not sure whether I grasp the whole problem, but can't you split the
vector up into the different rows, group by the row index and then apply
some kind of continuous aggregation or window function?
Maybe it helps if you can share some of your code with the community to
discuss the i
