org.apache.flink.streaming.api.operators

Interface Output<T>

Type Parameters:

T - The type of the elements that can be emitted.

All Superinterfaces:

Collector<T>

All Known Subinterfaces:

OutputWithChainingCheck<OUT>, WatermarkGaugeExposingOutput<T>

All Known Implementing Classes:

BroadcastingOutput, CopyingBroadcastingOutput, CopyingFirstInputOfTwoInputStreamOperatorOutput, CopyingOneInputStreamOperatorOutput, CopyingSecondInputOfTwoInputStreamOperatorOutput, CountingOutput, FinishedOnRestoreMainOperatorOutput, FirstInputOfTwoInputStreamOperatorOutput, OneInputStreamOperatorOutput, OutputBase, RecordWriterOutput, SecondInputOfTwoInputStreamOperatorOutput, TimestampedCollector

@PublicEvolving
public interface Output<T>
extends Collector<T>

A 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.

Method Summary

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	emitRecordAttributes(RecordAttributes recordAttributes) Emits a RecordAttributes from an operator.
void	emitWatermark(Watermark mark) Emits a Watermark from an operator.
void	emitWatermarkStatus(WatermarkStatus watermarkStatus)

Methods inherited from interface org.apache.flink.util.Collector

close, collect

Method Detail

emitWatermark

void emitWatermark(Watermark mark)

Emits a 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.

emitWatermarkStatus

void emitWatermarkStatus(WatermarkStatus watermarkStatus)

collect

<X> void collect(OutputTag<X> outputTag,
                 StreamRecord<X> record)

Emits a record to the side output identified by the given OutputTag.

Parameters:

record - The record to collect.

emitLatencyMarker

void emitLatencyMarker(LatencyMarker latencyMarker)

emitRecordAttributes

@Experimental
void emitRecordAttributes(RecordAttributes recordAttributes)

Emits a RecordAttributes from an operator. This element is broadcast to all downstream operators.