org.apache.flink.table.sources.wmstrategies

Class PunctuatedWatermarkAssigner

java.lang.Object

org.apache.flink.table.sources.wmstrategies.WatermarkStrategy

org.apache.flink.table.sources.wmstrategies.PunctuatedWatermarkAssigner

All Implemented Interfaces:

Serializable, Descriptor

@PublicEvolving
public abstract class PunctuatedWatermarkAssigner
extends WatermarkStrategy

A punctuated watermark assigner.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
PunctuatedWatermarkAssigner()

Method Summary

Modifier and Type	Method and Description
abstract Watermark	getWatermark(Row row, long timestamp) Returns the watermark for the current row or null if no watermark should be generated.

Methods inherited from class org.apache.flink.table.sources.wmstrategies.WatermarkStrategy

toProperties

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PunctuatedWatermarkAssigner

public PunctuatedWatermarkAssigner()

Method Detail

getWatermark

public abstract Watermark getWatermark(Row row,
                                       long timestamp)

Returns the watermark for the current row or null if no watermark should be generated.

Parameters:

row - The current row.

timestamp - The value of the timestamp attribute for the row.

Returns:

The watermark for this row or null if no watermark should be generated.