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

Class InputBase

java.lang.Object

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

All Implemented Interfaces:

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

Direct Known Subclasses:

FirstInputOfTwoInput, OneInput, SecondInputOfTwoInput

public abstract class InputBase
extends Object
implements org.apache.flink.streaming.api.operators.Input<org.apache.flink.table.data.RowData>, org.apache.flink.streaming.api.operators.KeyContextHandler

Base Input used in MultipleInputStreamOperatorBase.

Constructor Summary

Constructors

Constructor	Description
InputBase()

Method Summary

Modifier and Type	Method	Description
boolean	hasKeyContext()
void	setKeyContextElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<org.apache.flink.table.data.RowData> record)

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

processElement, processLatencyMarker, processRecordAttributes, processWatermark, processWatermark, processWatermarkStatus

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

hasKeyContext1, hasKeyContext2

Constructor Detail

InputBase

public InputBase()

Method Detail

setKeyContextElement

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

Specified by:

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

Throws:

Exception

hasKeyContext

public boolean hasKeyContext()

Specified by:

hasKeyContext in interface org.apache.flink.streaming.api.operators.KeyContextHandler