T- The type of the elements to which this assigner assigns timestamps.
@Deprecated public interface TimestampAssigner<T> extends TimestampAssigner<T>, Function
TimestampAssignerassigns event time timestamps to elements. These timestamps are used by all functions that operate on event time, for example event time windows.
Timestamps are represented in milliseconds since the Epoch (midnight, January 1, 1970 UTC).
|Modifier and Type||Method and Description|
Assigns a timestamp to an element, in milliseconds since the Epoch.
long extractTimestamp(T element, 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
element- The element that the timestamp will be assigned to.
recordTimestamp- The previous internal timestamp of the element, or a negative value, if no timestamp has been assigned yet.
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.