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

Class SecondInputOfTwoInputStreamOperatorOutput

java.lang.Object

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

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

All Implemented Interfaces:

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

public class SecondInputOfTwoInputStreamOperatorOutput
extends OutputBase

An Output that can be used to emit elements and other messages for the second input of TwoInputStreamOperator.

Constructor Summary

Constructors

Constructor	Description
SecondInputOfTwoInputStreamOperatorOutput(TwoInputStreamOperator<RowData,RowData,RowData> operator)

Method Summary

Modifier and Type	Method	Description
void	collect(StreamRecord<RowData> record)	Emits a record.
<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)
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

SecondInputOfTwoInputStreamOperatorOutput

public SecondInputOfTwoInputStreamOperatorOutput(TwoInputStreamOperator<RowData,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)