CoGroupedStreams.WithWindow sideOutputLateData and allowedLateness

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

CoGroupedStreams.WithWindow sideOutputLateData and allowedLateness

Yunus Olgun
Hi,

WindowedStream has sideOutputLateData and allowedLateness methods to handle late data. A similar functionality at CoGroupedStreams would have been nice. As it is, it silently ignores late data and it is error-prone.

- Is there a reason it does not exist?
- Any suggested workaround?