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

Class SecondInputOfTwoInput

java.lang.Object

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

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

All Implemented Interfaces:

Input<RowData>, KeyContextHandler, AsyncStateProcessing

public class SecondInputOfTwoInput
extends InputBase
implements AsyncStateProcessing

Input for the second input of TwoInputStreamOperator.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
<T> ThrowingConsumer<StreamRecord<T>,Exception>	getRecordProcessor(int inputId)	Get the record processor that could process record from input, which is the only entry for async processing.
boolean	isAsyncStateProcessingEnabled()	Get if the async state processing is enabled for this input/operator.
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.Input

processRecordAttributes

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

hasKeyContext1, hasKeyContext2

Constructor Detail

SecondInputOfTwoInput

public SecondInputOfTwoInput(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.

Specified by:

processElement in interface Input<RowData>

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.

Specified by:

processWatermark in interface Input<RowData>

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.

Specified by:

processLatencyMarker in interface Input<RowData>

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.

Specified by:

processWatermarkStatus in interface Input<RowData>

Throws:

Exception

See Also:

WatermarkStatus

isAsyncStateProcessingEnabled

@Internal
public final boolean isAsyncStateProcessingEnabled()

Description copied from interface: AsyncStateProcessing

Get if the async state processing is enabled for this input/operator.

Specified by:

isAsyncStateProcessingEnabled in interface AsyncStateProcessing

Returns:

ture if async state processing is enabled.

getRecordProcessor

@Internal
public final <T> ThrowingConsumer<StreamRecord<T>,Exception> getRecordProcessor(int inputId)

Description copied from interface: AsyncStateProcessing

Get the record processor that could process record from input, which is the only entry for async processing.

Specified by:

getRecordProcessor in interface AsyncStateProcessing

Parameters:

inputId - the input identifier, start from 1. Borrow the design from org.apache.flink.streaming.api.operators.AbstractInput#inputId. This is only relevant if there is multiple inputs for the instance.