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

Class MultipleInputStreamOperatorBase

java.lang.Object

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

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

All Implemented Interfaces:

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

Direct Known Subclasses:

BatchMultipleInputStreamOperator

public abstract class MultipleInputStreamOperatorBase
extends AbstractStreamOperatorV2<RowData>
implements MultipleInputStreamOperator<RowData>

Base MultipleInputStreamOperator to handle multiple inputs in table module.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected Map<Integer,InputSpec>	inputSpecMap
protected Deque<TableOperatorWrapper<?>>	topologicalOrderingOperators all operator as topological ordering in this multiple input operator.

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

config, latencyStats, LOG, metrics, output, processingTimeService

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	close() Closes all sub-operators in a multiple input operator effect way.
protected StreamConfig	createStreamConfig(StreamOperatorParameters<RowData> multipleInputOperatorParameters, TableOperatorWrapper<?> wrapper)
void	finish() Finish all sub-operators in a multiple input operator effect way.
List<Input>	getInputs()
void	open() Open all sub-operators in a multiple input operator from tail to head, contrary to StreamOperator.close() which happens head to tail (see close()).

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, processWatermark, processWatermarkStatus, reportOrForwardLatencyMarker, reportWatermark, setCurrentKey, setKeyContextElement1, setKeyContextElement2, snapshotState, snapshotState

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

Field Detail

inputSpecMap

protected final Map<Integer,InputSpec> inputSpecMap

topologicalOrderingOperators

protected final Deque<TableOperatorWrapper<?>> topologicalOrderingOperators

all operator as topological ordering in this multiple input operator.

Constructor Detail

MultipleInputStreamOperatorBase

public MultipleInputStreamOperatorBase(StreamOperatorParameters<RowData> parameters,
                                       List<InputSpec> inputSpecs,
                                       List<TableOperatorWrapper<?>> headWrappers,
                                       TableOperatorWrapper<?> tailWrapper)

Method Detail

getInputs

public List<Input> getInputs()

Specified by:

getInputs in interface MultipleInputStreamOperator<RowData>

open

public void open()
          throws Exception

Open all sub-operators in a multiple input operator from tail to head, contrary to StreamOperator.close() which happens head to tail (see close()).

Specified by:

open in interface StreamOperator<RowData>

Overrides:

open in class AbstractStreamOperatorV2<RowData>

Throws:

Exception - An exception in this method causes the operator to fail.

finish

public void finish()
            throws Exception

Finish all sub-operators in a multiple input operator effect way. Finishing happens from head to tail sub-operator in a multiple input operator, contrary to StreamOperator.open() which happens tail to head.

Specified by:

finish in interface StreamOperator<RowData>

Overrides:

finish in class AbstractStreamOperatorV2<RowData>

Throws:

Exception - An exception in this method causes the operator to fail.

close

public void close()
           throws Exception

Closes all sub-operators in a multiple input operator effect way. Closing happens from head to tail sub-operator in a multiple input operator, contrary to StreamOperator.open() which happens tail to head.

Specified by:

close in interface StreamOperator<RowData>

Overrides:

close in class AbstractStreamOperatorV2<RowData>

Throws:

Exception

createStreamConfig

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