Modifier and Type | Method and Description |
---|---|
WatermarkTracker |
FlinkKinesisConsumer.getWatermarkTracker() |
Modifier and Type | Method and Description |
---|---|
void |
FlinkKinesisConsumer.setWatermarkTracker(WatermarkTracker watermarkTracker)
Set the global watermark tracker.
|
Modifier and Type | Class and Description |
---|---|
class |
JobManagerWatermarkTracker
A
WatermarkTracker that shares state through GlobalAggregateManager . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.