public class SourceContextWatermarkOutputAdapter<T> extends Object implements WatermarkOutput
WatermarkOutput
that forwards calls to a SourceFunction.SourceContext
.Constructor and Description |
---|
SourceContextWatermarkOutputAdapter(SourceFunction.SourceContext<T> sourceContext) |
Modifier and Type | Method and Description |
---|---|
void |
emitWatermark(Watermark watermark)
Emits the given watermark.
|
void |
markActive()
Marks this output as active, meaning that downstream operations should wait for watermarks
from this output.
|
void |
markIdle()
Marks this output as idle, meaning that downstream operations do not wait for watermarks from
this output.
|
public SourceContextWatermarkOutputAdapter(SourceFunction.SourceContext<T> sourceContext)
public void emitWatermark(Watermark watermark)
WatermarkOutput
Emitting a watermark also implicitly marks the stream as active, ending previously marked idleness.
emitWatermark
in interface WatermarkOutput
public void markIdle()
WatermarkOutput
An output becomes active again as soon as the next watermark is emitted or WatermarkOutput.markActive()
is explicitly called.
markIdle
in interface WatermarkOutput
public void markActive()
WatermarkOutput
markActive
in interface WatermarkOutput
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.