@Public public interface WatermarkOutput
Modifier and Type | Method and Description |
---|---|
void |
emitWatermark(Watermark watermark)
Emits the given watermark.
|
void |
markIdle()
Marks this output as idle, meaning that downstream operations do not wait for watermarks from
this output.
|
void emitWatermark(Watermark watermark)
Emitting a watermark also implicitly marks the stream as active, ending previously marked idleness.
void markIdle()
An output becomes active again as soon as the next watermark is emitted.
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.