org.apache.flink.table.runtime.operators.multipleinput.output

Class OneInputStreamOperatorOutput

java.lang.Object

org.apache.flink.table.runtime.operators.multipleinput.output.OutputBase

org.apache.flink.table.runtime.operators.multipleinput.output.OneInputStreamOperatorOutput

All Implemented Interfaces:

Output<StreamRecord<RowData>>, Collector<StreamRecord<RowData>>

Direct Known Subclasses:

CopyingOneInputStreamOperatorOutput

public class OneInputStreamOperatorOutput
extends OutputBase

An Output that can be used to emit elements and other messages for OneInputStreamOperator.

Constructor Summary

Constructors

Constructor and Description
OneInputStreamOperatorOutput(OneInputStreamOperator<RowData,RowData> 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	collect(StreamRecord<RowData> record) Emits a record.
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)
protected <X> void	pushToOperator(StreamRecord<X> record)

Methods inherited from class org.apache.flink.table.runtime.operators.multipleinput.output.OutputBase

close

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

OneInputStreamOperatorOutput

public OneInputStreamOperatorOutput(OneInputStreamOperator<RowData,RowData> operator)

Method Detail

emitWatermark

public void emitWatermark(Watermark mark)

Description copied from interface: Output

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

public void emitWatermarkStatus(WatermarkStatus watermarkStatus)

emitLatencyMarker

public void emitLatencyMarker(LatencyMarker latencyMarker)

emitRecordAttributes

public void emitRecordAttributes(RecordAttributes recordAttributes)

Description copied from interface: Output

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

collect

public void collect(StreamRecord<RowData> record)

Description copied from interface: Collector

Emits a record.

Parameters:

record - The record to collect.

collect

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

Description copied from interface: Output

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

record - The record to collect.

pushToOperator

protected <X> void pushToOperator(StreamRecord<X> record)