T
- The type of the elements that can be emitted.@PublicEvolving public interface Output<T> extends Collector<T>
StreamOperator
is supplied with an object of
this interface that can be used to emit elements and other messages, such as barriers and
watermarks, from an operator.Modifier and Type | Method and Description |
---|---|
<X> void |
collect(OutputTag<X> outputTag,
StreamRecord<X> record)
Emits a record to the side output identified by the given
OutputTag . |
void |
emitLatencyMarker(LatencyMarker latencyMarker) |
void |
emitWatermark(Watermark mark)
Emits a
Watermark from an operator. |
void |
emitWatermarkStatus(WatermarkStatus watermarkStatus) |
void emitWatermark(Watermark mark)
Watermark
from an operator. This watermark is broadcast to all downstream
operators.
A watermark specifies that no element with a timestamp lower or equal to the watermark timestamp will be emitted in the future.
void emitWatermarkStatus(WatermarkStatus watermarkStatus)
<X> void collect(OutputTag<X> outputTag, StreamRecord<X> record)
OutputTag
.record
- The record to collect.void emitLatencyMarker(LatencyMarker latencyMarker)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.