@PublicEvolving public abstract class WatermarkTracker extends Object implements Closeable, Serializable
Modifier and Type | Class and Description |
---|---|
protected static class |
WatermarkTracker.WatermarkState
Watermark state.
|
Modifier and Type | Field and Description |
---|---|
static long |
DEFAULT_UPDATE_TIMEOUT_MILLIS |
Constructor and Description |
---|
WatermarkTracker() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
protected long |
getCurrentTime() |
protected String |
getSubtaskId() |
abstract long |
getUpdateTimeoutCount() |
protected long |
getUpdateTimeoutMillis() |
void |
open(RuntimeContext context) |
void |
setUpdateTimeoutMillis(long updateTimeoutMillis)
Subtasks that have not provided a watermark update within the configured interval will be
considered idle and excluded from target watermark calculation.
|
abstract long |
updateWatermark(long localWatermark)
Set the current watermark of the owning subtask and return the global low watermark based on
the current state snapshot.
|
public static final long DEFAULT_UPDATE_TIMEOUT_MILLIS
protected String getSubtaskId()
protected long getUpdateTimeoutMillis()
public abstract long getUpdateTimeoutCount()
public void setUpdateTimeoutMillis(long updateTimeoutMillis)
updateTimeoutMillis
- public abstract long updateWatermark(long localWatermark)
localWatermark
- protected long getCurrentTime()
public void open(RuntimeContext context)
public void close()
close
in interface Closeable
close
in interface AutoCloseable
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.