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

Class ProcessSetTableOperator

java.lang.Object

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

org.apache.flink.table.runtime.operators.process.AbstractProcessTableOperator

org.apache.flink.table.runtime.operators.process.ProcessSetTableOperator

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.state.CheckpointListener, 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, org.apache.flink.streaming.api.operators.Triggerable<org.apache.flink.table.data.RowData,Object>

public class ProcessSetTableOperator
extends AbstractProcessTableOperator
implements org.apache.flink.streaming.api.operators.MultipleInputStreamOperator<org.apache.flink.table.data.RowData>

Implementation of MultipleInputStreamOperator for ProcessTableFunction with at least one table with set semantics.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.table.runtime.operators.process.AbstractProcessTableOperator

AbstractProcessTableOperator.RunnerContext, AbstractProcessTableOperator.RunnerOnTimerContext

Field Summary

Fields inherited from class org.apache.flink.table.runtime.operators.process.AbstractProcessTableOperator

processTableRunner, tableSemantics

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
ProcessSetTableOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<org.apache.flink.table.data.RowData> parameters, List<RuntimeTableSemantics> tableSemantics, List<RuntimeStateInfo> stateInfos, ProcessTableRunner processTableRunner, HashFunction[] stateHashCode, RecordEqualiser[] stateEquals, RuntimeChangelogMode producedChangelogMode)

Method Summary

Modifier and Type	Method	Description
List<org.apache.flink.streaming.api.operators.Input>	getInputs()

Methods inherited from class org.apache.flink.table.runtime.operators.process.AbstractProcessTableOperator

onEventTime, onProcessingTime, open, processWatermark

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

beforeInitializeStateHandler, close, finish, 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, 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

close, finish, getMetricGroup, getOperatorAttributes, getOperatorID, initializeState, open, prepareSnapshotPreBarrier, setKeyContextElement1, setKeyContextElement2, snapshotState

Constructor Detail

ProcessSetTableOperator

public ProcessSetTableOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<org.apache.flink.table.data.RowData> parameters,
                               List<RuntimeTableSemantics> tableSemantics,
                               List<RuntimeStateInfo> stateInfos,
                               ProcessTableRunner processTableRunner,
                               HashFunction[] stateHashCode,
                               RecordEqualiser[] stateEquals,
                               RuntimeChangelogMode producedChangelogMode)

Method Detail

getInputs

public List<org.apache.flink.streaming.api.operators.Input> getInputs()

Specified by:

getInputs in interface org.apache.flink.streaming.api.operators.MultipleInputStreamOperator<org.apache.flink.table.data.RowData>