@Internal public static interface TimestampsAndWatermarks.WatermarkUpdateListener
Modifier and Type | Method and Description |
---|---|
void |
updateCurrentEffectiveWatermark(long watermark)
Effective watermark covers the
WatermarkStatus . |
void updateCurrentEffectiveWatermark(long watermark)
WatermarkStatus
. If an output becomes idle, this
method should be called with Long.MAX_VALUE
, but what is more important, once it
becomes active again it should call this method with the last emitted value of the
watermark.Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.