@Internal public class CompactCoordinatorStateHandlerFactory extends AbstractStreamOperatorFactory<Either<CommittableMessage<FileSinkCommittable>,CompactorRequest>> implements OneInputStreamOperatorFactory<CommittableMessage<FileSinkCommittable>,Either<CommittableMessage<FileSinkCommittable>,CompactorRequest>>
CompactCoordinatorStateHandler
.chainingStrategy, processingTimeService
Constructor and Description |
---|
CompactCoordinatorStateHandlerFactory(SerializableSupplierWithException<SimpleVersionedSerializer<FileSinkCommittable>,IOException> committableSerializerSupplier) |
Modifier and Type | Method and Description |
---|---|
<T extends StreamOperator<Either<CommittableMessage<FileSinkCommittable>,CompactorRequest>>> |
createStreamOperator(StreamOperatorParameters<Either<CommittableMessage<FileSinkCommittable>,CompactorRequest>> parameters)
Create the operator.
|
Class<? extends StreamOperator> |
getStreamOperatorClass(ClassLoader classLoader)
Returns the runtime class of the stream operator.
|
getChainingStrategy, getMailboxExecutor, setChainingStrategy, setMailboxExecutor, setProcessingTimeService
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getChainingStrategy, getOperatorAttributes, isInputTypeConfigurable, isLegacySource, isOutputTypeConfigurable, isStreamSource, setChainingStrategy, setInputType, setOutputType
public CompactCoordinatorStateHandlerFactory(SerializableSupplierWithException<SimpleVersionedSerializer<FileSinkCommittable>,IOException> committableSerializerSupplier)
public <T extends StreamOperator<Either<CommittableMessage<FileSinkCommittable>,CompactorRequest>>> T createStreamOperator(StreamOperatorParameters<Either<CommittableMessage<FileSinkCommittable>,CompactorRequest>> parameters)
StreamOperatorFactory
createStreamOperator
in interface StreamOperatorFactory<Either<CommittableMessage<FileSinkCommittable>,CompactorRequest>>
public Class<? extends StreamOperator> getStreamOperatorClass(ClassLoader classLoader)
StreamOperatorFactory
getStreamOperatorClass
in interface StreamOperatorFactory<Either<CommittableMessage<FileSinkCommittable>,CompactorRequest>>
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.