public class WatermarkAssignerOperatorFactory extends AbstractStreamOperatorFactory<RowData> implements OneInputStreamOperatorFactory<RowData,RowData>
WatermarkAssignerOperator
.chainingStrategy, processingTimeService
Constructor and Description |
---|
WatermarkAssignerOperatorFactory(int rowtimeFieldIndex,
long idleTimeout,
GeneratedWatermarkGenerator generatedWatermarkGenerator) |
Modifier and Type | Method and Description |
---|---|
StreamOperator |
createStreamOperator(StreamOperatorParameters initializer)
Create the operator.
|
Class<? extends StreamOperator> |
getStreamOperatorClass(ClassLoader classLoader)
Returns the runtime class of the stream operator.
|
getChainingStrategy, getMailboxExecutor, setChainingStrategy, setMailboxExecutor, setProcessingTimeService
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getChainingStrategy, getOperatorAttributes, isInputTypeConfigurable, isLegacySource, isOutputTypeConfigurable, isStreamSource, setChainingStrategy, setInputType, setOutputType
public WatermarkAssignerOperatorFactory(int rowtimeFieldIndex, long idleTimeout, GeneratedWatermarkGenerator generatedWatermarkGenerator)
public StreamOperator createStreamOperator(StreamOperatorParameters initializer)
StreamOperatorFactory
createStreamOperator
in interface StreamOperatorFactory<RowData>
public Class<? extends StreamOperator> getStreamOperatorClass(ClassLoader classLoader)
StreamOperatorFactory
getStreamOperatorClass
in interface StreamOperatorFactory<RowData>
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.