@PublicEvolving public class JobManagerWatermarkTracker extends WatermarkTracker
WatermarkTracker
that shares state through GlobalAggregateManager
.Modifier and Type | Class and Description |
---|---|
protected static class |
JobManagerWatermarkTracker.WatermarkResult
Watermark aggregation result.
|
protected static class |
JobManagerWatermarkTracker.WatermarkUpdate
Watermark aggregation input.
|
WatermarkTracker.WatermarkState
DEFAULT_UPDATE_TIMEOUT_MILLIS
Constructor and Description |
---|
JobManagerWatermarkTracker(String aggregateName) |
JobManagerWatermarkTracker(String aggregateName,
long logAccumulatorIntervalMillis) |
Modifier and Type | Method and Description |
---|---|
long |
getUpdateTimeoutCount() |
void |
open(RuntimeContext context) |
long |
updateWatermark(long localWatermark)
Set the current watermark of the owning subtask and return the global low watermark based on
the current state snapshot.
|
close, getCurrentTime, getSubtaskId, getUpdateTimeoutMillis, setUpdateTimeoutMillis
public JobManagerWatermarkTracker(String aggregateName)
public JobManagerWatermarkTracker(String aggregateName, long logAccumulatorIntervalMillis)
public long updateWatermark(long localWatermark)
WatermarkTracker
updateWatermark
in class WatermarkTracker
public void open(RuntimeContext context)
open
in class WatermarkTracker
public long getUpdateTimeoutCount()
getUpdateTimeoutCount
in class WatermarkTracker
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.