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

Class FusionStreamOperatorBase

  • 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 abstract class FusionStreamOperatorBase
extends org.apache.flink.streaming.api.operators.AbstractStreamOperatorV2<org.apache.flink.table.data.RowData>
implements org.apache.flink.streaming.api.operators.MultipleInputStreamOperator<org.apache.flink.table.data.RowData>, org.apache.flink.streaming.api.operators.InputSelectable, org.apache.flink.streaming.api.operators.BoundedMultiInput
    Base MultipleInputStreamOperator to handle multiple operator fusion codegen in table module.
    See Also:
    Serialized Form

    • Field Summary

      Fields 
      Modifier and Type Field Description
      protected org.apache.flink.streaming.api.operators.StreamOperatorParameters parameters  

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

        config, lastRecordAttributes, latencyStats, LOG, metrics, output, processingTimeService

    • Constructor Summary

      Constructors 
      Constructor Description
      FusionStreamOperatorBase​(org.apache.flink.streaming.api.operators.StreamOperatorParameters<org.apache.flink.table.data.RowData> parameters, int numberOfInputs)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      long computeMemorySize​(double operatorFraction)  
      org.apache.flink.streaming.runtime.tasks.StreamTask<?,​?> getContainingTask()  

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

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

      • Methods inherited from interface org.apache.flink.streaming.api.operators.BoundedMultiInput

        endInput

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

        notifyCheckpointAborted, notifyCheckpointComplete

      • Methods inherited from interface org.apache.flink.streaming.api.operators.InputSelectable

        nextSelection

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

        getCurrentKey, setCurrentKey

      • Methods inherited from interface org.apache.flink.streaming.api.operators.MultipleInputStreamOperator

        getInputs

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

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

    • Field Detail

      • parameters

        protected final org.apache.flink.streaming.api.operators.StreamOperatorParameters parameters

    • Constructor Detail

      • FusionStreamOperatorBase

        public FusionStreamOperatorBase​(org.apache.flink.streaming.api.operators.StreamOperatorParameters<org.apache.flink.table.data.RowData> parameters,
                                int numberOfInputs)

    • Method Detail

      • getContainingTask

        public org.apache.flink.streaming.runtime.tasks.StreamTask<?,​?> getContainingTask()

      • computeMemorySize

        public long computeMemorySize​(double operatorFraction)