Package org.apache.flink.streaming.api.transformations

Class LegacySinkTransformation<T>

  • Type Parameters:
    T - The type of the elements in the input LegacySinkTransformation
    @Internal
public class LegacySinkTransformation<T>
extends PhysicalTransformation<T>
    This Transformation represents a stream Sink.

    • Field Summary

      • Fields inherited from class org.apache.flink.api.dag.Transformation

        bufferTimeout, description, id, name, outputType, typeUsed, UPPER_BOUND_MAX_PARALLELISM

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      List<org.apache.flink.api.dag.Transformation<?>> getInputs()  
      StreamSink<T> getOperator()  
      StreamOperatorFactory<Object> getOperatorFactory()
      Returns the StreamOperatorFactory of this LegacySinkTransformation.
      org.apache.flink.api.java.functions.KeySelector<T,​?> getStateKeySelector()
      Returns the KeySelector that must be used for partitioning keyed state in this Sink.
      org.apache.flink.api.common.typeinfo.TypeInformation<?> getStateKeyType()  
      protected List<org.apache.flink.api.dag.Transformation<?>> getTransitivePredecessorsInternal()  
      boolean isSupportsConcurrentExecutionAttempts()  
      void setChainingStrategy​(ChainingStrategy strategy)
      Sets the chaining strategy of this Transformation.
      void setStateKeySelector​(org.apache.flink.api.java.functions.KeySelector<T,​?> stateKeySelector)
      Sets the KeySelector that must be used for partitioning keyed state of this Sink.
      void setStateKeyType​(org.apache.flink.api.common.typeinfo.TypeInformation<?> stateKeyType)  

      • Methods inherited from class org.apache.flink.api.dag.Transformation

        declareManagedMemoryUseCaseAtOperatorScope, declareManagedMemoryUseCaseAtSlotScope, equals, getBufferTimeout, getCoLocationGroupKey, getDescription, getId, getManagedMemoryOperatorScopeUseCaseWeights, getManagedMemorySlotScopeUseCases, getMaxParallelism, getMinResources, getName, getNewNodeId, getOutputType, getParallelism, getPreferredResources, getSlotSharingGroup, getTransitivePredecessors, getUid, getUserProvidedNodeHash, hashCode, isParallelismConfigured, setBufferTimeout, setCoLocationGroupKey, setDescription, setMaxParallelism, setName, setOutputType, setParallelism, setParallelism, setResources, setSlotSharingGroup, setSlotSharingGroup, setUid, setUidHash, toString, toStringWithoutId, updateManagedMemoryStateBackendUseCase

    • Constructor Detail

      • LegacySinkTransformation

        public LegacySinkTransformation​(org.apache.flink.api.dag.Transformation<T> input,
                                String name,
                                StreamSink<T> operator,
                                int parallelism,
                                boolean parallelismConfigured)
        Creates a new LegacySinkTransformation from the given input Transformation.
        Parameters:
        input - The input Transformation
        name - The name of the Transformation, this will be shown in Visualizations and the Log
        operator - The sink operator
        parallelism - The parallelism of this LegacySinkTransformation
        parallelismConfigured - If true, the parallelism of the transformation is explicitly set and should be respected. Otherwise the parallelism can be changed at runtime.

      • LegacySinkTransformation

        public LegacySinkTransformation​(org.apache.flink.api.dag.Transformation<T> input,
                                String name,
                                StreamOperatorFactory<Object> operatorFactory,
                                int parallelism)

      • LegacySinkTransformation

        public LegacySinkTransformation​(org.apache.flink.api.dag.Transformation<T> input,
                                String name,
                                StreamOperatorFactory<Object> operatorFactory,
                                int parallelism,
                                boolean parallelismConfigured)

    • Method Detail

      • getOperator

        @VisibleForTesting
public StreamSink<T> getOperator()

      • setStateKeySelector

        public void setStateKeySelector​(org.apache.flink.api.java.functions.KeySelector<T,​?> stateKeySelector)
        Sets the KeySelector that must be used for partitioning keyed state of this Sink.
        Parameters:
        stateKeySelector - The KeySelector to set

      • setStateKeyType

        public void setStateKeyType​(org.apache.flink.api.common.typeinfo.TypeInformation<?> stateKeyType)

      • getStateKeyType

        public org.apache.flink.api.common.typeinfo.TypeInformation<?> getStateKeyType()

      • getTransitivePredecessorsInternal

        protected List<org.apache.flink.api.dag.Transformation<?>> getTransitivePredecessorsInternal()
        Specified by:
        getTransitivePredecessorsInternal in class org.apache.flink.api.dag.Transformation<T>

      • getInputs

        public List<org.apache.flink.api.dag.Transformation<?>> getInputs()
        Specified by:
        getInputs in class org.apache.flink.api.dag.Transformation<T>