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).
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
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.