public class CollectSinkOperatorFactory<IN> extends SimpleUdfStreamOperatorFactory<Object> implements CoordinatedOperatorFactory<Object>
CollectSinkOperator
.chainingStrategy, processingTimeService
Constructor and Description |
---|
CollectSinkOperatorFactory(TypeSerializer<IN> serializer,
String accumulatorName) |
CollectSinkOperatorFactory(TypeSerializer<IN> serializer,
String accumulatorName,
long maxBytesPerBatch,
int socketTimeoutMillis) |
Modifier and Type | Method and Description |
---|---|
<T extends StreamOperator<Object>> |
createStreamOperator(StreamOperatorParameters<Object> parameters)
Create the operator.
|
OperatorCoordinator.Provider |
getCoordinatorProvider(String operatorName,
OperatorID operatorID)
Get the operator coordinator provider for this operator.
|
getUserFunction, getUserFunctionClassName
getOperator, getStreamOperatorClass, isInputTypeConfigurable, isLegacySource, isOutputTypeConfigurable, isStreamSource, of, setChainingStrategy, setInputType, setOutputType
getChainingStrategy, setProcessingTimeService
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getChainingStrategy, getStreamOperatorClass, isInputTypeConfigurable, isLegacySource, isOutputTypeConfigurable, isStreamSource, setChainingStrategy, setInputType, setOutputType
public CollectSinkOperatorFactory(TypeSerializer<IN> serializer, String accumulatorName)
public CollectSinkOperatorFactory(TypeSerializer<IN> serializer, String accumulatorName, long maxBytesPerBatch, int socketTimeoutMillis)
public <T extends StreamOperator<Object>> T createStreamOperator(StreamOperatorParameters<Object> parameters)
StreamOperatorFactory
createStreamOperator
in interface CoordinatedOperatorFactory<Object>
createStreamOperator
in interface StreamOperatorFactory<Object>
createStreamOperator
in class SimpleOperatorFactory<Object>
public OperatorCoordinator.Provider getCoordinatorProvider(String operatorName, OperatorID operatorID)
CoordinatedOperatorFactory
getCoordinatorProvider
in interface CoordinatedOperatorFactory<Object>
operatorName
- the name of the operator.operatorID
- the id of the operator.OperatorCoordinator
for this operator.Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.