org.apache.flink.table.sources.wmstrategies

类 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

所有已实现的接口:

Serializable, org.apache.flink.table.descriptors.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.

另请参阅:

序列化表格

构造器概要

构造器

构造器和说明
BoundedOutOfOrderTimestamps(long delay)

方法概要

限定符和类型	方法和说明
boolean	equals(Object o)
org.apache.flink.streaming.api.watermark.Watermark	getWatermark() Returns the current watermark.
int	hashCode()
void	nextTimestamp(long timestamp) Updates the assigner with the next timestamp.
Map<String,String>	toProperties()

从类继承的方法 java.lang.Object

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

构造器详细资料

BoundedOutOfOrderTimestamps

public BoundedOutOfOrderTimestamps(long delay)

参数:

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

方法详细资料

nextTimestamp

public void nextTimestamp(long timestamp)

从类复制的说明: PeriodicWatermarkAssigner

Updates the assigner with the next timestamp.

指定者:

nextTimestamp 在类中 PeriodicWatermarkAssigner

参数:

timestamp - The next timestamp to update the assigner.

getWatermark

public org.apache.flink.streaming.api.watermark.Watermark getWatermark()

从类复制的说明: PeriodicWatermarkAssigner

Returns the current watermark.

指定者:

getWatermark 在类中 PeriodicWatermarkAssigner

返回:

The current watermark.

toProperties

public Map<String,String> toProperties()

指定者:

toProperties 在接口中 org.apache.flink.table.descriptors.Descriptor

覆盖:

toProperties 在类中 org.apache.flink.table.sources.wmstrategies.WatermarkStrategy

equals

public boolean equals(Object o)

覆盖:

equals 在类中 Object

hashCode

public int hashCode()

覆盖:

hashCode 在类中 Object