org.apache.flink.table.runtime.generated

Class GeneratedWatermarkGeneratorSupplier.DefaultWatermarkGenerator

java.lang.Object

org.apache.flink.table.runtime.generated.GeneratedWatermarkGeneratorSupplier.DefaultWatermarkGenerator

All Implemented Interfaces:

WatermarkGenerator<RowData>

Enclosing class:

GeneratedWatermarkGeneratorSupplier

public static class GeneratedWatermarkGeneratorSupplier.DefaultWatermarkGenerator
extends Object
implements WatermarkGenerator<RowData>

Wrapper of the code-generated WatermarkGenerator.

Constructor Summary

Constructors

Constructor and Description
DefaultWatermarkGenerator(WatermarkGenerator watermarkGenerator, WatermarkEmitStrategy watermarkEmitStrategy)

Method Summary

Modifier and Type	Method and Description
void	onEvent(RowData event, long eventTimestamp, WatermarkOutput output) Called for every event, allows the watermark generator to examine and remember the event timestamps, or to emit a watermark based on the event itself.
void	onPeriodicEmit(WatermarkOutput output) Called periodically, and might emit a new watermark, or not.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultWatermarkGenerator

public DefaultWatermarkGenerator(WatermarkGenerator watermarkGenerator,
                                 WatermarkEmitStrategy watermarkEmitStrategy)

Method Detail

onEvent

public void onEvent(RowData event,
                    long eventTimestamp,
                    WatermarkOutput output)

Description copied from interface: WatermarkGenerator

Called for every event, allows the watermark generator to examine and remember the event timestamps, or to emit a watermark based on the event itself.

Specified by:

onEvent in interface WatermarkGenerator<RowData>

onPeriodicEmit

public void onPeriodicEmit(WatermarkOutput output)

Description copied from interface: WatermarkGenerator

Called periodically, and might emit a new watermark, or not.

The interval in which this method is called and Watermarks are generated depends on ExecutionConfig.getAutoWatermarkInterval().

Specified by:

onPeriodicEmit in interface WatermarkGenerator<RowData>