Details
-
New Feature
-
Status: Closed
-
Major
-
Resolution: Won't Fix
-
None
-
None
-
None
Description
Currently CoProcessFunction can not react to changes watermark advancement. By passing processWatermark calls to function we would give a way to perform some actions on watermark advancement, like state clean up or emitting some results after accumulating some data.
Attachments
Attachments
Issue Links
- links to