public class WatermarkAssignerOperatorFactory extends Object implements OneInputStreamOperatorFactory<BaseRow,BaseRow>
WatermarkAssignerOperator
.Constructor and Description |
---|
WatermarkAssignerOperatorFactory(int rowtimeFieldIndex,
long idleTimeout,
GeneratedWatermarkGenerator generatedWatermarkGenerator) |
Modifier and Type | Method and Description |
---|---|
StreamOperator |
createStreamOperator(StreamTask containingTask,
StreamConfig config,
Output output)
Create the operator.
|
ChainingStrategy |
getChainingStrategy()
Get the chaining strategy of operator factory.
|
Class<? extends StreamOperator> |
getStreamOperatorClass(ClassLoader classLoader)
Returns the runtime class of the stream operator.
|
void |
setChainingStrategy(ChainingStrategy strategy)
Set the chaining strategy for operator factory.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
isInputTypeConfigurable, isOutputTypeConfigurable, isStreamSource, setInputType, setOutputType
public WatermarkAssignerOperatorFactory(int rowtimeFieldIndex, long idleTimeout, GeneratedWatermarkGenerator generatedWatermarkGenerator)
public StreamOperator createStreamOperator(StreamTask containingTask, StreamConfig config, Output output)
StreamOperatorFactory
createStreamOperator
in interface StreamOperatorFactory<BaseRow>
public void setChainingStrategy(ChainingStrategy strategy)
StreamOperatorFactory
setChainingStrategy
in interface StreamOperatorFactory<BaseRow>
public ChainingStrategy getChainingStrategy()
StreamOperatorFactory
getChainingStrategy
in interface StreamOperatorFactory<BaseRow>
public Class<? extends StreamOperator> getStreamOperatorClass(ClassLoader classLoader)
StreamOperatorFactory
getStreamOperatorClass
in interface StreamOperatorFactory<BaseRow>
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.