@Public public class WatermarksWithIdleness<T> extends Object implements WatermarkGenerator<T>
Constructor and Description |
---|
WatermarksWithIdleness(WatermarkGenerator<T> watermarks,
java.time.Duration idleTimeout)
Creates a new WatermarksWithIdleness generator to the given generator idleness detection with
the given timeout.
|
Modifier and Type | Method and Description |
---|---|
void |
onEvent(T 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 WatermarksWithIdleness(WatermarkGenerator<T> watermarks, java.time.Duration idleTimeout)
watermarks
- The original watermark generator.idleTimeout
- The timeout for the idleness detection.public void onEvent(T event, long eventTimestamp, WatermarkOutput output)
WatermarkGenerator
onEvent
in interface WatermarkGenerator<T>
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<T>
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.