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

Class GlobalCommitterTransform<CommT>

  • Type Parameters:
    CommT - 
    @Internal
public class GlobalCommitterTransform<CommT>
extends org.apache.flink.api.dag.Transformation<Void>
    Transformation for global committer. Only used to fetch if the pipeline is streaming or batch with the respective GlobalCommitterTransformationTranslator.

    • Field Summary

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

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

    • Constructor Summary

      Constructors 
      Constructor Description
      GlobalCommitterTransform​(DataStream<CommittableMessage<CommT>> inputStream, org.apache.flink.util.function.SerializableSupplier<org.apache.flink.api.connector.sink2.Committer<CommT>> committerFactory, org.apache.flink.util.function.SerializableSupplier<org.apache.flink.core.io.SimpleVersionedSerializer<CommT>> committableSerializer)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      org.apache.flink.util.function.SerializableSupplier<org.apache.flink.core.io.SimpleVersionedSerializer<CommT>> getCommittableSerializer()  
      org.apache.flink.util.function.SerializableSupplier<org.apache.flink.api.connector.sink2.Committer<CommT>> getCommitterFactory()  
      List<org.apache.flink.api.dag.Transformation<?>> getInputs()  
      DataStream<CommittableMessage<CommT>> getInputStream()  
      protected List<org.apache.flink.api.dag.Transformation<?>> getTransitivePredecessorsInternal()  

      • 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

      • GlobalCommitterTransform

        public GlobalCommitterTransform​(DataStream<CommittableMessage<CommT>> inputStream,
                                org.apache.flink.util.function.SerializableSupplier<org.apache.flink.api.connector.sink2.Committer<CommT>> committerFactory,
                                org.apache.flink.util.function.SerializableSupplier<org.apache.flink.core.io.SimpleVersionedSerializer<CommT>> committableSerializer)

    • Method Detail

      • getTransitivePredecessorsInternal

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

      • getInputs

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

      • getCommitterFactory

        public org.apache.flink.util.function.SerializableSupplier<org.apache.flink.api.connector.sink2.Committer<CommT>> getCommitterFactory()

      • getCommittableSerializer

        public org.apache.flink.util.function.SerializableSupplier<org.apache.flink.core.io.SimpleVersionedSerializer<CommT>> getCommittableSerializer()