CommT
- The committable type of the Committer
.@Internal public class StreamingCommitterOperatorFactory<CommT> extends AbstractStreamOperatorFactory<CommT>
StreamOperatorFactory
for StreamingCommitterOperator
.chainingStrategy, processingTimeService
Constructor and Description |
---|
StreamingCommitterOperatorFactory(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 Class<? extends StreamOperator> getStreamOperatorClass(ClassLoader classLoader)
StreamOperatorFactory
public <T extends StreamOperator<CommT>> T createStreamOperator(StreamOperatorParameters<CommT> parameters)
StreamOperatorFactory
createStreamOperator
in interface StreamOperatorFactory<CommT>
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.