Login  Register

CoGroupedStreams.WithWindow sideOutputLateData and allowedLateness

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

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?