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.AsyncStateProcessing

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

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	isAsyncStateProcessingEnabled()
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

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

isAsyncStateProcessingEnabled

@Internal
public final boolean isAsyncStateProcessingEnabled()

Specified by:

isAsyncStateProcessingEnabled in interface org.apache.flink.streaming.runtime.operators.asyncprocessing.AsyncStateProcessing

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.AsyncStateProcessing