garyelephant opened a new pull request #14099:
URL: https://github.com/apache/flink/pull/14099
## What is the purpose of the change
In production environment, when we are do some window operation, such as
window aggregation, using data stream api, developers are always asked to not
only trigger the window operation when the watermark pass the max timestamp of
window, but also trigger it both by fixed event time interval and fixed count
of event.The reason why we want to do this is we are looking forward to get the
frequently updated window operation result, other than waiting for a long time
until the watermark pass the max timestamp of window.This is very useful in
reporting and other BI applications.
For now the default triggers provided by flink can not close this
requirement, so I developed a New Trigger, so called
CountAndContinuousEventTimeTrigger, combine ContinuousEventTimeTrigger with
CountTrigger to do the above thing.
## Verifying this change
This change is already covered by existing tests, such as
*ContinuousEventTimeTriggerTest* and *CountTriggerTest*.
## Does this pull request potentially affect one of the following parts:
- Dependencies (does it add or upgrade a dependency): (no)
- The public API, i.e., is any changed class annotated with
`@Public(Evolving)`: (yes)
- The serializers: (no)
- The runtime per-record code paths (performance sensitive): (no)
- Anything that affects deployment or recovery: JobManager (and its
components), Checkpointing, Kubernetes/Yarn/Mesos, ZooKeeper: (no)
- The S3 file system connector: (no)
## Documentation
- Does this pull request introduce a new feature? (yes)
- If yes, how is the feature documented? (JavaDocs)
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
