PeriodicWatermarkAssignerWrapper (Flink : Table : Runtime 1.18.1-cp3 API)

java.lang.Object
- org.apache.flink.table.runtime.operators.wmassigners.PeriodicWatermarkAssignerWrapper

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.eventtime.TimestampAssigner<org.apache.flink.table.data.RowData>, org.apache.flink.api.common.functions.Function, org.apache.flink.streaming.api.functions.AssignerWithPeriodicWatermarks<org.apache.flink.table.data.RowData>, org.apache.flink.streaming.api.functions.TimestampAssigner<org.apache.flink.table.data.RowData>
```
@Internal
public class PeriodicWatermarkAssignerWrapper
extends Object
implements org.apache.flink.streaming.api.functions.AssignerWithPeriodicWatermarks<org.apache.flink.table.data.RowData>
```
Generates periodic watermarks based on a PeriodicWatermarkAssigner.

See Also:

Serialized Form

Field Summary
- Fields inherited from interface org.apache.flink.api.common.eventtime.TimestampAssigner
  NO_TIMESTAMP

Constructor Summary

Constructors
Constructor	Description
`PeriodicWatermarkAssignerWrapper(org.apache.flink.table.sources.wmstrategies.PeriodicWatermarkAssigner assigner, int timeFieldIdx)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`long`	`extractTimestamp(org.apache.flink.table.data.RowData row, long recordTimestamp)`
`org.apache.flink.streaming.api.watermark.Watermark`	`getCurrentWatermark()`

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

- Constructor Detail
  - PeriodicWatermarkAssignerWrapper
```
public PeriodicWatermarkAssignerWrapper(org.apache.flink.table.sources.wmstrategies.PeriodicWatermarkAssigner assigner,
                                        int timeFieldIdx)
```
    Parameters:
    
    timeFieldIdx - the index of the rowtime attribute.
    
    assigner - the watermark assigner.
- Method Detail
  - getCurrentWatermark
```
@Nullable
public org.apache.flink.streaming.api.watermark.Watermark getCurrentWatermark()
```
    Specified by:
    
    getCurrentWatermark in interface org.apache.flink.streaming.api.functions.AssignerWithPeriodicWatermarks<org.apache.flink.table.data.RowData>
  - extractTimestamp
```
public long extractTimestamp(org.apache.flink.table.data.RowData row,
                             long recordTimestamp)
```
    Specified by:
    
    extractTimestamp in interface org.apache.flink.api.common.eventtime.TimestampAssigner<org.apache.flink.table.data.RowData>
    
    Specified by:
    
    extractTimestamp in interface org.apache.flink.streaming.api.functions.TimestampAssigner<org.apache.flink.table.data.RowData>