I think Till is referring to regular windows. The *All variants combine the
data into one task.
On Fri, Feb 17, 2017 at 4:14 PM, Sonex wrote:
> Hi Till,
>
> when you say parallel windows, what do you mean? Do you mean the use of
> timeWindowAll which has all the elements of a window in a single
Hi Till,
when you say parallel windows, what do you mean? Do you mean the use of
timeWindowAll which has all the elements of a window in a single task?
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Cartesian-product-over-windows-tp11676p11
Hi Ioannis,
with a flatMap operation which replicates elements and assigning them a
proper key followed by a keyBy operation you can practically generate all
different kinds of partitionings.
So if you first collect the data in parallel windows, you can then
replicate half of the data of each win
