org.apache.flink.table.sources.wmstrategies

Class AscendingTimestamps

java.lang.Object

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

org.apache.flink.table.sources.wmstrategies.PeriodicWatermarkAssigner

org.apache.flink.table.sources.wmstrategies.AscendingTimestamps

All Implemented Interfaces:

Serializable, Descriptor

@PublicEvolving
public final class AscendingTimestamps
extends PeriodicWatermarkAssigner

A watermark strategy for ascending rowtime attributes.

Emits a watermark of the maximum observed timestamp so far minus 1. Rows that have a timestamp equal to the max timestamp are not late.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
AscendingTimestamps()

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object obj)
Watermark	getWatermark() Returns the current watermark.
int	hashCode()
void	nextTimestamp(long timestamp) Updates the assigner with the next timestamp.
Map<String,String>	toProperties() This method is a default implementation that uses java serialization and it is discouraged.

Methods inherited from class java.lang.Object

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

Constructor Detail

AscendingTimestamps

public AscendingTimestamps()

Method Detail

nextTimestamp

public void nextTimestamp(long timestamp)

Description copied from class: PeriodicWatermarkAssigner

Updates the assigner with the next timestamp.

Specified by:

nextTimestamp in class PeriodicWatermarkAssigner

Parameters:

timestamp - The next timestamp to update the assigner.

toProperties

public Map<String,String> toProperties()

Description copied from class: WatermarkStrategy

This method is a default implementation that uses java serialization and it is discouraged. All implementation should provide a more specific set of properties.

Specified by:

toProperties in interface Descriptor

Overrides:

toProperties in class WatermarkStrategy

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

getWatermark

public Watermark getWatermark()

Description copied from class: PeriodicWatermarkAssigner

Returns the current watermark.

Specified by:

getWatermark in class PeriodicWatermarkAssigner

Returns:

The current watermark.