Package org.apache.flink.connector.file.sink.compactor.operator

Class CompactCoordinatorFactory

  • All Implemented Interfaces:
    Serializable, org.apache.flink.streaming.api.operators.OneInputStreamOperatorFactory<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>,​CompactorRequest>, org.apache.flink.streaming.api.operators.StreamOperatorFactory<CompactorRequest>, org.apache.flink.streaming.runtime.tasks.ProcessingTimeServiceAware
    @Internal
public class CompactCoordinatorFactory
extends org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory<CompactorRequest>
implements org.apache.flink.streaming.api.operators.OneInputStreamOperatorFactory<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>,​CompactorRequest>
    Factory for CompactCoordinator.
    See Also:
    Serialized Form

    • Field Summary

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

        chainingStrategy, processingTimeService

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      <T extends org.apache.flink.streaming.api.operators.StreamOperator<CompactorRequest>>
      T      		 createStreamOperator​(org.apache.flink.streaming.api.operators.StreamOperatorParameters<CompactorRequest> parameters)  
      Class<? extends org.apache.flink.streaming.api.operators.StreamOperator> getStreamOperatorClass​(ClassLoader classLoader)  

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

        getChainingStrategy, getMailboxExecutor, setChainingStrategy, setMailboxExecutor, setProcessingTimeService

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

        getChainingStrategy, getOperatorAttributes, isInputTypeConfigurable, isLegacySource, isOutputTypeConfigurable, isStreamSource, setChainingStrategy, setInputType, setOutputType

    • Constructor Detail

      • CompactCoordinatorFactory

        public CompactCoordinatorFactory​(FileCompactStrategy strategy,
                                 org.apache.flink.util.function.SerializableSupplierWithException<org.apache.flink.core.io.SimpleVersionedSerializer<FileSinkCommittable>,​IOException> committableSerializerSupplier)

    • Method Detail

      • createStreamOperator

        public <T extends org.apache.flink.streaming.api.operators.StreamOperator<CompactorRequest>> T createStreamOperator​(org.apache.flink.streaming.api.operators.StreamOperatorParameters<CompactorRequest> parameters)
        Specified by:
        createStreamOperator in interface org.apache.flink.streaming.api.operators.StreamOperatorFactory<CompactorRequest>

      • getStreamOperatorClass

        public Class<? extends org.apache.flink.streaming.api.operators.StreamOperator> getStreamOperatorClass​(ClassLoader classLoader)
        Specified by:
        getStreamOperatorClass in interface org.apache.flink.streaming.api.operators.StreamOperatorFactory<CompactorRequest>