Hi,
yes, this works well in cases and I was also thinking about adding
something like this to Flink.
There can be problems if you use a trigger other than EventTimeTrigger that
possibly fires multiple times or if you specify an allowed lateness. In
those cases, you would overcount elements in the
Hi,
As a self training exercise I've defined a class extending WindowedStream
for implementing a proof of concept for a parallel version of
AllWindowStream
/**
* Tries to create a parallel version of a AllWindowStream for a DataStream
* by creating a KeyedStream by using as key the hash of the
