Class IndexedCombinedWatermarkStatus
- java.lang.Object
-
- org.apache.flink.api.common.eventtime.IndexedCombinedWatermarkStatus
-
@Internal public final class IndexedCombinedWatermarkStatus extends Object
Represents combined value and status of a watermark for a set number of input partial watermarks.
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static IndexedCombinedWatermarkStatusforInputsCount(int inputsCount)longgetCombinedWatermark()booleanisIdle()booleanupdateStatus(int index, boolean idle)Updates the idleness for the given partial watermark.booleanupdateWatermark(int index, long timestamp)Updates the value for the given partial watermark.
-
-
-
Method Detail
-
forInputsCount
public static IndexedCombinedWatermarkStatus forInputsCount(int inputsCount)
-
updateWatermark
public boolean updateWatermark(int index, long timestamp)Updates the value for the given partial watermark. Can update both the global idleness as well as the combined watermark value.- Returns:
- true, if the combined watermark value changed. The global idleness needs to be
checked separately via
isIdle()
-
getCombinedWatermark
public long getCombinedWatermark()
-
updateStatus
public boolean updateStatus(int index, boolean idle)Updates the idleness for the given partial watermark. Can update both the global idleness as well as the combined watermark value.- Returns:
- true, if the combined watermark value changed. The global idleness needs to be
checked separately via
isIdle()
-
isIdle
public boolean isIdle()
-
-