BoundedOutOfOrderWatermarkGenerator (Flink : 2.0-SNAPSHOT API)

java.lang.Object
- org.apache.flink.api.common.functions.AbstractRichFunction
- - org.apache.flink.table.runtime.generated.WatermarkGenerator
  - - org.apache.flink.table.runtime.operators.wmassigners.BoundedOutOfOrderWatermarkGenerator

All Implemented Interfaces:

Serializable, Function, RichFunction
```
public class BoundedOutOfOrderWatermarkGenerator
extends WatermarkGenerator
```
A watermark generator for rowtime attributes which are out-of-order by a bounded time interval.
Emits watermarks which are the observed timestamp minus the specified delay.

See Also:

Serialized Form

Constructor Summary

Constructors
Constructor Description

BoundedOutOfOrderWatermarkGenerator(int rowtimeIndex, long delay)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`Long`	`currentWatermark(RowData row)`	Returns the watermark for the current row or null if no watermark should be generated.

Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction
close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext

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

- Constructor Detail
  - BoundedOutOfOrderWatermarkGenerator
```
public BoundedOutOfOrderWatermarkGenerator(int rowtimeIndex,
                                           long delay)
```
    Parameters:
    
    rowtimeIndex - the field index of rowtime attribute, the value of rowtime should never be null.
    
    delay - The delay by which watermarks are behind the observed timestamp.
- Method Detail
  - currentWatermark
```
@Nullable
public Long currentWatermark(RowData row)
```
    Description copied from class: WatermarkGenerator
    
    Returns the watermark for the current row or null if no watermark should be generated.
    
    Specified by:
    
    currentWatermark in class WatermarkGenerator
    
    Parameters:
    
    row - The current row.
    
    Returns:
    
    The watermark for this row or null if no watermark should be generated.