@Experimental public abstract class AbstractStreamOperatorFactory<OUT> extends Object implements StreamOperatorFactory<OUT>, ProcessingTimeServiceAware
ProcessingTimeServiceAware
interface which enables stream operators to access ProcessingTimeService
.Modifier and Type | Field and Description |
---|---|
protected ChainingStrategy |
chainingStrategy |
protected ProcessingTimeService |
processingTimeService |
Constructor and Description |
---|
AbstractStreamOperatorFactory() |
Modifier and Type | Method and Description |
---|---|
ChainingStrategy |
getChainingStrategy()
Get the chaining strategy of operator factory.
|
void |
setChainingStrategy(ChainingStrategy strategy)
Set the chaining strategy for operator factory.
|
void |
setProcessingTimeService(ProcessingTimeService processingTimeService) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
createStreamOperator, getStreamOperatorClass, isInputTypeConfigurable, isLegacySource, isOutputTypeConfigurable, isStreamSource, setInputType, setOutputType
protected ChainingStrategy chainingStrategy
protected transient ProcessingTimeService processingTimeService
public void setChainingStrategy(ChainingStrategy strategy)
StreamOperatorFactory
setChainingStrategy
in interface StreamOperatorFactory<OUT>
public ChainingStrategy getChainingStrategy()
StreamOperatorFactory
getChainingStrategy
in interface StreamOperatorFactory<OUT>
public void setProcessingTimeService(ProcessingTimeService processingTimeService)
setProcessingTimeService
in interface ProcessingTimeServiceAware
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.