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

Class CompactorOperatorStateHandlerFactory

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

    • Field Summary

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

        chainingStrategy, processingTimeService

    • Constructor Summary

      Constructors 
      Constructor Description
      CompactorOperatorStateHandlerFactory​(org.apache.flink.util.function.SerializableSupplierWithException<org.apache.flink.core.io.SimpleVersionedSerializer<FileSinkCommittable>,​IOException> committableSerializerSupplier, org.apache.flink.util.function.SerializableSupplierWithException<org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter<?,​String>,​IOException> bucketWriterProvider)  

    • 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.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>>>
      T      		 createStreamOperator​(org.apache.flink.streaming.api.operators.StreamOperatorParameters<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>> 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

      • CompactorOperatorStateHandlerFactory

        public CompactorOperatorStateHandlerFactory​(org.apache.flink.util.function.SerializableSupplierWithException<org.apache.flink.core.io.SimpleVersionedSerializer<FileSinkCommittable>,​IOException> committableSerializerSupplier,
                                            org.apache.flink.util.function.SerializableSupplierWithException<org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter<?,​String>,​IOException> bucketWriterProvider)

    • Method Detail

      • createStreamOperator

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

      • 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.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>>