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

Class FirstInputOfTwoInput

java.lang.Object

org.apache.flink.table.runtime.operators.multipleinput.input.InputBase

org.apache.flink.table.runtime.operators.multipleinput.input.FirstInputOfTwoInput

All Implemented Interfaces:

Input<RowData>, KeyContextHandler

public class FirstInputOfTwoInput
extends InputBase

Input for the first input of TwoInputStreamOperator.

Constructor Summary

Constructors

Constructor and Description
FirstInputOfTwoInput(TwoInputStreamOperator<RowData,RowData,RowData> operator)

Method Summary

Modifier and Type	Method and Description
void	processElement(StreamRecord<RowData> element) Processes one element that arrived on this input of the MultipleInputStreamOperator.
void	processLatencyMarker(LatencyMarker latencyMarker) Processes a LatencyMarker that arrived on the first input of this two-input operator.
void	processWatermark(Watermark mark) Processes a Watermark that arrived on the first input of this two-input operator.
void	processWatermarkStatus(WatermarkStatus watermarkStatus) Processes a WatermarkStatus that arrived on this input of the MultipleInputStreamOperator.

Methods inherited from class org.apache.flink.table.runtime.operators.multipleinput.input.InputBase

hasKeyContext, setKeyContextElement

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.streaming.api.operators.KeyContextHandler

hasKeyContext1, hasKeyContext2

Constructor Detail

FirstInputOfTwoInput

public FirstInputOfTwoInput(TwoInputStreamOperator<RowData,RowData,RowData> operator)

Method Detail

processElement

public void processElement(StreamRecord<RowData> element)
                    throws Exception

Description copied from interface: Input

Processes one element that arrived on this input of the MultipleInputStreamOperator. This method is guaranteed to not be called concurrently with other methods of the operator.

Throws:

Exception

processWatermark

public void processWatermark(Watermark mark)
                      throws Exception

Description copied from interface: Input

Processes a Watermark that arrived on the first input of this two-input operator. This method is guaranteed to not be called concurrently with other methods of the operator.

Throws:

Exception

See Also:

Watermark

processLatencyMarker

public void processLatencyMarker(LatencyMarker latencyMarker)
                          throws Exception

Description copied from interface: Input

Processes a LatencyMarker that arrived on the first input of this two-input operator. This method is guaranteed to not be called concurrently with other methods of the operator.

Throws:

Exception

See Also:

LatencyMarker

processWatermarkStatus

public void processWatermarkStatus(WatermarkStatus watermarkStatus)
                            throws Exception

Description copied from interface: Input

Processes a WatermarkStatus that arrived on this input of the MultipleInputStreamOperator. This method is guaranteed to not be called concurrently with other methods of the operator.

Throws:

Exception

See Also:

WatermarkStatus