pyflink.datastream.connectors.kinesis.WatermarkTracker#
- class WatermarkTracker(j_watermark_tracker)[source]#
The watermark tracker is responsible for aggregating watermarks across distributed operators. It can be used for sub tasks of a single Flink source as well as multiple heterogeneous sources or other operators.The class essentially functions like a distributed hash table that enclosing operators can use to adopt their processing / IO rates
Methods
job_manager_watermark_tracker(aggregate_name)