Hello!

I have a data source that emits Arrays that I collect into windows via
countWindow. Rather than parallelize my subsequent operations by groups of
these arrays, I'd like to parallelize my operations across the elements of
the array (rows rather than columns, if you will) within each window.

Some context: I'm attempting a time series analysis across some number of
voxels. Each time step, I receive an Array of voxel data, but I'd like to
analyze the voxels across time.

It sounds like this approach mixes DataStream and DataSet concepts (where
each window is a DataSet), which I know are not supported. Perhaps there is
some other way to accomplish this task?

Thanks!
Daniel

Reply via email to