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

Class BatchMultipleInputStreamOperator

java.lang.Object

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

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

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

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.state.CheckpointListener, org.apache.flink.streaming.api.operators.BoundedMultiInput, org.apache.flink.streaming.api.operators.InputSelectable, org.apache.flink.streaming.api.operators.KeyContext, org.apache.flink.streaming.api.operators.MultipleInputStreamOperator<org.apache.flink.table.data.RowData>, org.apache.flink.streaming.api.operators.StreamOperator<org.apache.flink.table.data.RowData>, org.apache.flink.streaming.api.operators.StreamOperatorStateHandler.CheckpointedStreamOperator

public class BatchMultipleInputStreamOperator
extends MultipleInputStreamOperatorBase
implements org.apache.flink.streaming.api.operators.BoundedMultiInput, org.apache.flink.streaming.api.operators.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	Description
BatchMultipleInputStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<org.apache.flink.table.data.RowData> parameters, List<InputSpec> inputSpecs, List<TableOperatorWrapper<?>> headWrapper, TableOperatorWrapper<?> tailWrapper)

Method Summary

Modifier and Type	Method	Description
protected org.apache.flink.streaming.api.graph.StreamConfig	createStreamConfig(org.apache.flink.streaming.api.operators.StreamOperatorParameters<org.apache.flink.table.data.RowData> multipleInputOperatorParameters, TableOperatorWrapper<?> wrapper)
void	endInput(int inputId)
org.apache.flink.streaming.api.operators.InputSelection	nextSelection()

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

beforeInitializeStateHandler, getCurrentKey, getExecutionConfig, getInternalTimerService, getKeyedStateBackend, getKeyedStateStore, getMetricGroup, getOperatorConfig, getOperatorID, getOperatorName, getOperatorStateBackend, getOrCreateKeyedState, getPartitionedState, getPartitionedState, getProcessingTimeService, getRuntimeContext, getTimeServiceManager, getUserCodeClassloader, initializeState, initializeState, internalSetKeyContextElement, isAsyncKeyOrderedProcessingEnabled, 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.api.common.state.CheckpointListener

notifyCheckpointAborted, notifyCheckpointComplete

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

getCurrentKey, setCurrentKey

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

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

Constructor Detail

BatchMultipleInputStreamOperator

public BatchMultipleInputStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<org.apache.flink.table.data.RowData> parameters,
                                        List<InputSpec> inputSpecs,
                                        List<TableOperatorWrapper<?>> headWrapper,
                                        TableOperatorWrapper<?> tailWrapper)

Method Detail

endInput

public void endInput(int inputId)
              throws Exception

Specified by:

endInput in interface org.apache.flink.streaming.api.operators.BoundedMultiInput

Throws:

Exception

nextSelection

public org.apache.flink.streaming.api.operators.InputSelection nextSelection()

Specified by:

nextSelection in interface org.apache.flink.streaming.api.operators.InputSelectable

createStreamConfig

protected org.apache.flink.streaming.api.graph.StreamConfig createStreamConfig(org.apache.flink.streaming.api.operators.StreamOperatorParameters<org.apache.flink.table.data.RowData> multipleInputOperatorParameters,
                                                                               TableOperatorWrapper<?> wrapper)

Overrides:

createStreamConfig in class MultipleInputStreamOperatorBase