PeriodicWatermarkAssignerWrapper (Flink : Table : Runtime 2.1.2-cp1 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.eventtime.TimestampAssignerSupplier<org.apache.flink.table.data.RowData>, org.apache.flink.api.common.eventtime.WatermarkGeneratorSupplier<org.apache.flink.table.data.RowData>, org.apache.flink.api.common.eventtime.WatermarkStrategy<org.apache.flink.table.data.RowData>, org.apache.flink.streaming.runtime.operators.util.WatermarkStrategyWithPeriodicWatermarks<org.apache.flink.table.data.RowData>
```
@Internal
public class PeriodicWatermarkAssignerWrapper
extends Object
implements org.apache.flink.streaming.runtime.operators.util.WatermarkStrategyWithPeriodicWatermarks<org.apache.flink.table.data.RowData>
```
Generates periodic watermarks based on a PeriodicWatermarkAssigner.

See Also:

Serialized Form

Nested Class Summary
- Nested classes/interfaces inherited from interface org.apache.flink.api.common.eventtime.TimestampAssignerSupplier
  org.apache.flink.api.common.eventtime.TimestampAssignerSupplier.Context, org.apache.flink.api.common.eventtime.TimestampAssignerSupplier.SupplierFromSerializableTimestampAssigner<T extends Object>
- Nested classes/interfaces inherited from interface org.apache.flink.api.common.eventtime.WatermarkGeneratorSupplier
  org.apache.flink.api.common.eventtime.WatermarkGeneratorSupplier.Context

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

Methods inherited from interface org.apache.flink.api.common.eventtime.WatermarkStrategy
getAlignmentParameters, withIdleness, withTimestampAssigner, withTimestampAssigner, withWatermarkAlignment, withWatermarkAlignment

Methods inherited from interface org.apache.flink.streaming.runtime.operators.util.WatermarkStrategyWithPeriodicWatermarks
createTimestampAssigner, createWatermarkGenerator

- 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.runtime.operators.util.WatermarkStrategyWithPeriodicWatermarks<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>