org.apache.flink.table.sources.wmstrategies

Class BoundedOutOfOrderTimestamps

java.lang.Object

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

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

org.apache.flink.table.sources.wmstrategies.BoundedOutOfOrderTimestamps

All Implemented Interfaces:

Serializable, Descriptor

@PublicEvolving
public final class BoundedOutOfOrderTimestamps
extends PeriodicWatermarkAssigner

A watermark strategy for rowtime attributes which are out-of-order by a bounded time interval.

Emits watermarks which are the maximum observed timestamp minus the specified delay.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
BoundedOutOfOrderTimestamps(long delay)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
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

BoundedOutOfOrderTimestamps

public BoundedOutOfOrderTimestamps(long delay)

Parameters:

delay - The delay by which watermarks are behind the maximum observed timestamp.

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.

getWatermark

public Watermark getWatermark()

Description copied from class: PeriodicWatermarkAssigner

Returns the current watermark.

Specified by:

getWatermark in class PeriodicWatermarkAssigner

Returns:

The current watermark.

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

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object