WatermarkAssignerOperatorFactory (Flink : 2.0-SNAPSHOT API)

java.lang.Object
- org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory<RowData>
- - org.apache.flink.table.runtime.operators.wmassigners.WatermarkAssignerOperatorFactory

All Implemented Interfaces:

Serializable, OneInputStreamOperatorFactory<RowData,RowData>, StreamOperatorFactory<RowData>, ProcessingTimeServiceAware
```
public class WatermarkAssignerOperatorFactory
extends AbstractStreamOperatorFactory<RowData>
implements OneInputStreamOperatorFactory<RowData,RowData>
```
The factory of WatermarkAssignerOperator.

See Also:

Serialized Form

Field Summary
- Fields inherited from class org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory
  chainingStrategy, processingTimeService

Constructor Summary

Constructors
Constructor	Description
`WatermarkAssignerOperatorFactory(int rowtimeFieldIndex, long idleTimeout, GeneratedWatermarkGenerator generatedWatermarkGenerator)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`StreamOperator`	`createStreamOperator(StreamOperatorParameters initializer)`	Create the operator.
`Class<? extends StreamOperator>`	`getStreamOperatorClass(ClassLoader classLoader)`	Returns the runtime class of the stream operator.

Methods inherited from class org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory
getChainingStrategy, getMailboxExecutor, setChainingStrategy, setMailboxExecutor, setProcessingTimeService

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.streaming.api.operators.StreamOperatorFactory
getChainingStrategy, getOperatorAttributes, isInputTypeConfigurable, isLegacySource, isOutputTypeConfigurable, isStreamSource, setChainingStrategy, setInputType, setOutputType

- Constructor Detail
  - WatermarkAssignerOperatorFactory
```
public WatermarkAssignerOperatorFactory(int rowtimeFieldIndex,
                                        long idleTimeout,
                                        GeneratedWatermarkGenerator generatedWatermarkGenerator)
```
- Method Detail
  - createStreamOperator
```
public StreamOperator createStreamOperator(StreamOperatorParameters initializer)
```
    Description copied from interface: StreamOperatorFactory
    
    Create the operator. Sets access to the context and the output.
    
    Specified by:
    
    createStreamOperator in interface StreamOperatorFactory<RowData>
  - getStreamOperatorClass
```
public Class<? extends StreamOperator> getStreamOperatorClass(ClassLoader classLoader)
```
    Description copied from interface: StreamOperatorFactory
    
    Returns the runtime class of the stream operator.
    
    Specified by:
    
    getStreamOperatorClass in interface StreamOperatorFactory<RowData>