org.apache.flink.streaming.api.operators.source

Interface TimestampsAndWatermarks.WatermarkUpdateListener

All Known Implementing Classes:

SourceOperator

Enclosing interface:

TimestampsAndWatermarks<T>

@Internal
public static interface TimestampsAndWatermarks.WatermarkUpdateListener

Lets the owner/creator of the output know about latest emitted watermark.

Method Summary

Modifier and Type	Method and Description
void	updateCurrentEffectiveWatermark(long watermark) Update the effective watermark.
void	updateCurrentSplitWatermark(String splitId, long watermark) Notifies about changes to per split watermarks.
void	updateIdle(boolean isIdle) It should be called once the idle is changed.

Method Detail

updateIdle

void updateIdle(boolean isIdle)

It should be called once the idle is changed.

updateCurrentEffectiveWatermark

void updateCurrentEffectiveWatermark(long watermark)

Update the effective watermark. If an output becomes idle, please call this#updateIdle instead of update the watermark to Long.MAX_VALUE. Because the output needs to distinguish between idle and real watermark.

updateCurrentSplitWatermark

void updateCurrentSplitWatermark(String splitId,
                                 long watermark)

Notifies about changes to per split watermarks.