beam-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Antony Mayi <>
Subject exclusive window per event
Date Fri, 31 Mar 2017 06:19:45 GMT
is there a way to implement windowing so that each input event gets into its own exclusive
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).
View raw message