@Public public interface WatermarkOutput
|Modifier and Type||Method and Description|
Emits the given watermark.
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.
An output becomes active again as soon as the next watermark is emitted.
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.