T- The type of the elements that can be emitted.
@PublicEvolving public interface Output<T> extends Collector<T>
StreamOperatoris 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|
void emitWatermark(Watermark mark)
Watermarkfrom 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 emitLatencyMarker(LatencyMarker latencyMarker)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.