Package 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:

org.apache.flink.streaming.api.operators.Input<org.apache.flink.table.data.RowData>, org.apache.flink.streaming.api.operators.KeyContextHandler, org.apache.flink.streaming.runtime.operators.asyncprocessing.AsyncKeyOrderedProcessing

public class FirstInputOfTwoInput
extends InputBase
implements org.apache.flink.streaming.runtime.operators.asyncprocessing.AsyncKeyOrderedProcessing

Input for the first input of TwoInputStreamOperator.

Constructor Summary

Constructors

Constructor	Description
FirstInputOfTwoInput(org.apache.flink.streaming.api.operators.TwoInputStreamOperator<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData> operator)

Method Summary

Modifier and Type	Method	Description
<T> org.apache.flink.util.function.ThrowingConsumer<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<T>,Exception>	getRecordProcessor(int inputId)
boolean	isAsyncKeyOrderedProcessingEnabled()
void	processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<org.apache.flink.table.data.RowData> element)
void	processLatencyMarker(org.apache.flink.streaming.runtime.streamrecord.LatencyMarker latencyMarker)
void	processWatermark(org.apache.flink.streaming.api.watermark.Watermark mark)
void	processWatermarkStatus(org.apache.flink.streaming.runtime.watermarkstatus.WatermarkStatus watermarkStatus)

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, processWatermark

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

hasKeyContext1, hasKeyContext2

Constructor Detail

FirstInputOfTwoInput

public FirstInputOfTwoInput(org.apache.flink.streaming.api.operators.TwoInputStreamOperator<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData> operator)

Method Detail

processElement

public void processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<org.apache.flink.table.data.RowData> element)
                    throws Exception

Specified by:

processElement in interface org.apache.flink.streaming.api.operators.Input<org.apache.flink.table.data.RowData>

Throws:

Exception

processWatermark

public void processWatermark(org.apache.flink.streaming.api.watermark.Watermark mark)
                      throws Exception

Specified by:

processWatermark in interface org.apache.flink.streaming.api.operators.Input<org.apache.flink.table.data.RowData>

Throws:

Exception

processLatencyMarker

public void processLatencyMarker(org.apache.flink.streaming.runtime.streamrecord.LatencyMarker latencyMarker)
                          throws Exception

Specified by:

processLatencyMarker in interface org.apache.flink.streaming.api.operators.Input<org.apache.flink.table.data.RowData>

Throws:

Exception

processWatermarkStatus

public void processWatermarkStatus(org.apache.flink.streaming.runtime.watermarkstatus.WatermarkStatus watermarkStatus)
                            throws Exception

Specified by:

processWatermarkStatus in interface org.apache.flink.streaming.api.operators.Input<org.apache.flink.table.data.RowData>

Throws:

Exception

isAsyncKeyOrderedProcessingEnabled

@Internal
public final boolean isAsyncKeyOrderedProcessingEnabled()

Specified by:

isAsyncKeyOrderedProcessingEnabled in interface org.apache.flink.streaming.runtime.operators.asyncprocessing.AsyncKeyOrderedProcessing

getRecordProcessor

@Internal
public final <T> org.apache.flink.util.function.ThrowingConsumer<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<T>,Exception> getRecordProcessor(int inputId)

Specified by:

getRecordProcessor in interface org.apache.flink.streaming.runtime.operators.asyncprocessing.AsyncKeyOrderedProcessing