CommT
- The committable type of the GlobalCommitter
.GlobalCommT
- The global committable type of the GlobalCommitter
.public class StreamingGlobalCommitterOperatorFactory<CommT,GlobalCommT> extends AbstractStreamOperatorFactory<CommT>
chainingStrategy, processingTimeService
Constructor and Description |
---|
StreamingGlobalCommitterOperatorFactory(Sink<?,CommT,?,GlobalCommT> 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 StreamingGlobalCommitterOperatorFactory(Sink<?,CommT,?,GlobalCommT> sink)
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.