public abstract class WatermarkGenerator extends AbstractRichFunction
WatermarkGenerator
is used to generate watermark based the input elements.Constructor and Description |
---|
WatermarkGenerator() |
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.
|
close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
open
@Nullable public abstract Long currentWatermark(RowData row) throws Exception
row
- The current row.Exception
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.