public static class GeneratedWatermarkGeneratorSupplier.DefaultWatermarkGenerator extends Object implements WatermarkGenerator<RowData>
WatermarkGenerator
.Constructor and Description |
---|
DefaultWatermarkGenerator(WatermarkGenerator watermarkGenerator,
WatermarkEmitStrategy watermarkEmitStrategy) |
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.
|
public DefaultWatermarkGenerator(WatermarkGenerator watermarkGenerator, WatermarkEmitStrategy watermarkEmitStrategy)
public void onEvent(RowData event, long eventTimestamp, WatermarkOutput output)
WatermarkGenerator
onEvent
in interface WatermarkGenerator<RowData>
public void onPeriodicEmit(WatermarkOutput output)
WatermarkGenerator
The interval in which this method is called and Watermarks are generated depends on ExecutionConfig.getAutoWatermarkInterval()
.
onPeriodicEmit
in interface WatermarkGenerator<RowData>
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.