CommT
- the type of the committableGlobalCommT
- the type of the global committable@Internal public final class CommitterOperatorFactory<CommT,GlobalCommT> extends AbstractStreamOperatorFactory<byte[]> implements OneInputStreamOperatorFactory<byte[],byte[]>
StreamOperatorFactory
for CommitterOperator
.chainingStrategy, processingTimeService
Constructor and Description |
---|
CommitterOperatorFactory(Sink<?,CommT,?,GlobalCommT> sink,
boolean batch) |
Modifier and Type | Method and Description |
---|---|
<T extends StreamOperator<byte[]>> |
createStreamOperator(StreamOperatorParameters<byte[]> 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, isInputTypeConfigurable, isLegacySource, isOutputTypeConfigurable, isStreamSource, setChainingStrategy, setInputType, setOutputType
public CommitterOperatorFactory(Sink<?,CommT,?,GlobalCommT> sink, boolean batch)
public <T extends StreamOperator<byte[]>> T createStreamOperator(StreamOperatorParameters<byte[]> parameters)
StreamOperatorFactory
createStreamOperator
in interface StreamOperatorFactory<byte[]>
public Class<? extends StreamOperator> getStreamOperatorClass(ClassLoader classLoader)
StreamOperatorFactory
getStreamOperatorClass
in interface StreamOperatorFactory<byte[]>
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.