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

Class CompactCoordinatorStateHandlerFactory

  • All Implemented Interfaces:
    Serializable, org.apache.flink.streaming.api.operators.OneInputStreamOperatorFactory<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>,​org.apache.flink.types.Either<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>,​CompactorRequest>>, org.apache.flink.streaming.api.operators.StreamOperatorFactory<org.apache.flink.types.Either<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>,​CompactorRequest>>, org.apache.flink.streaming.runtime.tasks.ProcessingTimeServiceAware
    @Internal
public class CompactCoordinatorStateHandlerFactory
extends org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory<org.apache.flink.types.Either<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>,​CompactorRequest>>
implements org.apache.flink.streaming.api.operators.OneInputStreamOperatorFactory<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>,​org.apache.flink.types.Either<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>,​CompactorRequest>>
    Factory for CompactCoordinatorStateHandler.
    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<org.apache.flink.types.Either<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>,​CompactorRequest>>>
      T      		 createStreamOperator​(org.apache.flink.streaming.api.operators.StreamOperatorParameters<org.apache.flink.types.Either<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>,​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

      • CompactCoordinatorStateHandlerFactory

        public CompactCoordinatorStateHandlerFactory​(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<org.apache.flink.types.Either<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>,​CompactorRequest>>> T createStreamOperator​(org.apache.flink.streaming.api.operators.StreamOperatorParameters<org.apache.flink.types.Either<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>,​CompactorRequest>> parameters)
        Specified by:
        createStreamOperator in interface org.apache.flink.streaming.api.operators.StreamOperatorFactory<org.apache.flink.types.Either<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>,​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<org.apache.flink.types.Either<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>,​CompactorRequest>>