T- The type of the elements that get timestamps assigned.
@Public public final class IngestionTimeAssigner<T> extends Object implements TimestampAssigner<T>
|Constructor and Description|
|Modifier and Type||Method and Description|
Assigns a timestamp to an element, in milliseconds since the Epoch.
public 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. If the element did not carry a
timestamp before, this value is
element- The element that the timestamp will be assigned to.
recordTimestamp- The current 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.