@Internal public class PeriodicWatermarkAssignerWrapper extends Object implements AssignerWithPeriodicWatermarks<RowData>
|Constructor and Description
|Modifier and Type
|Method and Description
Assigns a timestamp to an element, in milliseconds since the Epoch.
Returns the current watermark.
public PeriodicWatermarkAssignerWrapper(PeriodicWatermarkAssigner assigner, int timeFieldIdx)
timeFieldIdx - the index of the rowtime attribute.
assigner - the watermark assigner.
null to indicate that no new Watermark
The returned watermark will be emitted only if it is non-null and its timestamp is larger than that of the previously emitted watermark (to preserve the contract of ascending watermarks). If the current watermark is still identical to the previous one, no progress in event time has happened since the previous call to this method. If a null value is returned, or the timestamp of the returned watermark is smaller than that of the last emitted one, then no new watermark will be generated.
The interval in which this method is called and Watermarks are generated depends on
public long extractTimestamp(RowData row, long recordTimestamp)
The method is passed the previously assigned timestamp of the element. That previous
timestamp may have been assigned from a previous assigner, by ingestion time. If the element
did not carry a timestamp before, this value is
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.