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:

Input<RowData>, KeyContextHandler

Direct Known Subclasses:

FirstInputOfTwoInput, OneInput, SecondInputOfTwoInput

public abstract class InputBase
extends Object
implements Input<RowData>, KeyContextHandler

Base Input used in MultipleInputStreamOperatorBase.

Constructor Summary

Constructors

Constructor and Description
InputBase()

Method Summary

Modifier and Type	Method and Description
boolean	hasKeyContext() Whether the Input has "KeyContext".
void	setKeyContextElement(StreamRecord<RowData> record) Set the correct key context before processing the 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, 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(StreamRecord<RowData> record)
                          throws Exception

Description copied from interface: Input

Set the correct key context before processing the record. Used for example to extract key from the record and pass that key to the state backends. This method is guaranteed to not be called concurrently with other methods of the operator.

Specified by:

setKeyContextElement in interface Input<RowData>

Throws:

Exception

hasKeyContext

public boolean hasKeyContext()

Description copied from interface: KeyContextHandler

Whether the Input has "KeyContext". If false, we can omit the call of Input.setKeyContextElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IN>) for each record.

Specified by:

hasKeyContext in interface KeyContextHandler

Returns:

True if the Input has "KeyContext", false otherwise.