org.apache.flink.table.runtime.generated

Class WatermarkGenerator

java.lang.Object

org.apache.flink.api.common.functions.AbstractRichFunction

org.apache.flink.table.runtime.generated.WatermarkGenerator

All Implemented Interfaces:

Serializable, Function, RichFunction

Direct Known Subclasses:

BoundedOutOfOrderWatermarkGenerator

public abstract class WatermarkGenerator
extends AbstractRichFunction

The WatermarkGenerator is used to generate watermark based the input elements.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
WatermarkGenerator()

Method Summary

Modifier and Type	Method and Description
abstract Long	currentWatermark(RowData row) Returns the watermark for the current row or null if no watermark should be generated.

Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction

close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext

Methods inherited from class java.lang.Object

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

Constructor Detail

WatermarkGenerator

public WatermarkGenerator()

Method Detail

currentWatermark

@Nullable
public abstract Long currentWatermark(RowData row)
                                         throws Exception

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

Parameters:

row - The current row.

Returns:

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

Throws:

Exception