CommT
- The committable type of the GlobalCommitter
GlobalCommT
- The committable type of the GlobalCommitter
public final class BatchGlobalCommitterOperatorFactory<CommT,GlobalCommT> extends AbstractStreamOperatorFactory<GlobalCommT> implements OneInputStreamOperatorFactory<CommT,GlobalCommT>
StreamOperatorFactory
for BatchGlobalCommitterOperator
.chainingStrategy, processingTimeService
Constructor and Description |
---|
BatchGlobalCommitterOperatorFactory(Sink<?,CommT,?,GlobalCommT> sink) |
Modifier and Type | Method and Description |
---|---|
<T extends StreamOperator<GlobalCommT>> |
createStreamOperator(StreamOperatorParameters<GlobalCommT> 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 BatchGlobalCommitterOperatorFactory(Sink<?,CommT,?,GlobalCommT> sink)
public <T extends StreamOperator<GlobalCommT>> T createStreamOperator(StreamOperatorParameters<GlobalCommT> parameters)
StreamOperatorFactory
createStreamOperator
in interface StreamOperatorFactory<GlobalCommT>
public Class<? extends StreamOperator> getStreamOperatorClass(ClassLoader classLoader)
StreamOperatorFactory
getStreamOperatorClass
in interface StreamOperatorFactory<GlobalCommT>
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.