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

Class BatchMultipleInputStreamOperator

java.lang.Object

org.apache.flink.streaming.api.operators.AbstractStreamOperatorV2<RowData>

org.apache.flink.table.runtime.operators.multipleinput.MultipleInputStreamOperatorBase

org.apache.flink.table.runtime.operators.multipleinput.BatchMultipleInputStreamOperator

All Implemented Interfaces:

Serializable, CheckpointListener, BoundedMultiInput, InputSelectable, KeyContext, MultipleInputStreamOperator<RowData>, StreamOperator<RowData>, StreamOperatorStateHandler.CheckpointedStreamOperator

public class BatchMultipleInputStreamOperator
extends MultipleInputStreamOperatorBase
implements BoundedMultiInput, InputSelectable

A MultipleInputStreamOperatorBase to handle batch operators.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.flink.table.runtime.operators.multipleinput.MultipleInputStreamOperatorBase

inputSpecMap, topologicalOrderingOperators

Fields inherited from class org.apache.flink.streaming.api.operators.AbstractStreamOperatorV2

combinedWatermark, config, lastRecordAttributes, latencyStats, LOG, metrics, output, processingTimeService, stateHandler, timeServiceManager

Constructor Summary

Constructors

Constructor and Description
BatchMultipleInputStreamOperator(StreamOperatorParameters<RowData> parameters, List<InputSpec> inputSpecs, List<TableOperatorWrapper<?>> headWrapper, TableOperatorWrapper<?> tailWrapper)

Method Summary

Modifier and Type	Method and Description
protected StreamConfig	createStreamConfig(StreamOperatorParameters<RowData> multipleInputOperatorParameters, TableOperatorWrapper<?> wrapper)
void	endInput(int inputId) It is notified that no more data will arrive from the input identified by the inputId.
InputSelection	nextSelection() Returns the next InputSelection that wants to get the record.

Methods inherited from class org.apache.flink.table.runtime.operators.multipleinput.MultipleInputStreamOperatorBase

close, finish, getInputs, open

Methods inherited from class org.apache.flink.streaming.api.operators.AbstractStreamOperatorV2

getCurrentKey, getExecutionConfig, getInternalTimerService, getKeyedStateBackend, getKeyedStateStore, getMetricGroup, getOperatorConfig, getOperatorID, getOperatorName, getOperatorStateBackend, getOrCreateKeyedState, getPartitionedState, getPartitionedState, getProcessingTimeService, getRuntimeContext, getTimeServiceManager, getUserCodeClassloader, initializeState, initializeState, internalSetKeyContextElement, isUsingCustomRawKeyedState, notifyCheckpointAborted, notifyCheckpointComplete, prepareSnapshotPreBarrier, processRecordAttributes, processWatermark, processWatermarkStatus, reportOrForwardLatencyMarker, reportWatermark, setCurrentKey, setKeyContextElement1, setKeyContextElement2, snapshotState, snapshotState, useSplittableTimers

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

getMetricGroup, getOperatorAttributes, getOperatorID, initializeState, prepareSnapshotPreBarrier, setKeyContextElement1, setKeyContextElement2, snapshotState

Methods inherited from interface org.apache.flink.api.common.state.CheckpointListener

notifyCheckpointAborted, notifyCheckpointComplete

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

getCurrentKey, setCurrentKey

Constructor Detail

BatchMultipleInputStreamOperator

public BatchMultipleInputStreamOperator(StreamOperatorParameters<RowData> parameters,
                                        List<InputSpec> inputSpecs,
                                        List<TableOperatorWrapper<?>> headWrapper,
                                        TableOperatorWrapper<?> tailWrapper)

Method Detail

endInput

public void endInput(int inputId)
              throws Exception

Description copied from interface: BoundedMultiInput

It is notified that no more data will arrive from the input identified by the inputId. The inputId is numbered starting from 1, and `1` indicates the first input.

WARNING: It is not safe to use this method to commit any transactions or other side effects! You can use this method to e.g. flush data buffered for the given input or implement an ordered reading from multiple inputs via InputSelectable.

Specified by:

endInput in interface BoundedMultiInput

Throws:

Exception

nextSelection

public InputSelection nextSelection()

Description copied from interface: InputSelectable

Returns the next InputSelection that wants to get the record. This method is guaranteed to not be called concurrently with other methods of the operator.

Specified by:

nextSelection in interface InputSelectable

createStreamConfig

protected StreamConfig createStreamConfig(StreamOperatorParameters<RowData> multipleInputOperatorParameters,
                                          TableOperatorWrapper<?> wrapper)

Overrides:

createStreamConfig in class MultipleInputStreamOperatorBase