CommT
- The committable type of the Committer
.public final class BatchCommitterOperatorFactory<CommT> extends AbstractStreamOperatorFactory<CommT> implements OneInputStreamOperatorFactory<CommT,CommT>
StreamOperatorFactory
for BatchCommitterOperator
.chainingStrategy, processingTimeService
Constructor and Description |
---|
BatchCommitterOperatorFactory(Sink<?,CommT,?,?> sink) |
Modifier and Type | Method and Description |
---|---|
<T extends StreamOperator<CommT>> |
createStreamOperator(StreamOperatorParameters<CommT> parameters)
Create the operator.
|
Class<? extends StreamOperator> |
getStreamOperatorClass(ClassLoader classLoader)
Returns the runtime class of the stream operator.
|
getChainingStrategy, setChainingStrategy, setProcessingTimeService
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getChainingStrategy, isInputTypeConfigurable, isLegacySource, isOutputTypeConfigurable, isStreamSource, setChainingStrategy, setInputType, setOutputType
public <T extends StreamOperator<CommT>> T createStreamOperator(StreamOperatorParameters<CommT> parameters)
StreamOperatorFactory
createStreamOperator
in interface StreamOperatorFactory<CommT>
public Class<? extends StreamOperator> getStreamOperatorClass(ClassLoader classLoader)
StreamOperatorFactory
getStreamOperatorClass
in interface StreamOperatorFactory<CommT>
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.