pyflink.datastream.connectors.kinesis.WatermarkTracker

class WatermarkTracker(j_watermark_tracker)

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)