org.apache.flink.api.common.eventtime

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

Modifier and Type	Method and Description
static IndexedCombinedWatermarkStatus	forInputsCount(int inputsCount)
long	getCombinedWatermark()
boolean	isIdle()
boolean	updateStatus(int index, boolean idle) Updates the idleness for the given partial watermark.
boolean	updateWatermark(int index, long timestamp) Updates the value for the given partial watermark.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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()