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?