> In your proposed solution, it probably could be expressed as a new
merging WindowFn. You would assign each Green element to two tagged windows
that were GreenFromOrange and GreenToBlue type, and have a separate window
tag for OrangeWindow and BlueWindow. Then GreenFromOrange merges with
OrangeWin
Hi Community,
We are working on adding output time independent of firing specification
for all timers. Currently, we have set the required holds for Direct Runner
and Dataflow. We need to do the same for Flink as well. Need some
assistance in how we can achieve this.
Watermark holds for Flink to
