Hi,
is there a way to implement windowing so that each input event gets into its
own exclusive window?
I can see the PartitioningWindowFn can be extended. If I implement the
assignWindow to return new IntervalWindow with both start and end time set to
the even time and in case there are two distinct events arriving at the same
time (indistinguishable within Instant granularity), would this be processed as
two separate windows without interfering the event data during any
transformations?
My motivation is to to be able to flatmap individual input events into a
pcollection of multiple elements that - being a single exclusive window - can
be grouped/... independently of other events (even if the other event has same
time).
thanks,Antony.
