@Public public final class RecordTimestampAssigner<E> extends Object implements TimestampAssigner<E>
TimestampAssigner
that forwards the already-assigned timestamp. This is for use when
records come out of a source with valid timestamps, for example from the Kafka Metadata.NO_TIMESTAMP
Constructor and Description |
---|
RecordTimestampAssigner() |
Modifier and Type | Method and Description |
---|---|
long |
extractTimestamp(E element,
long recordTimestamp)
Assigns a timestamp to an element, in milliseconds since the Epoch.
|
public long extractTimestamp(E element, long recordTimestamp)
TimestampAssigner
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 TimestampAssigner.NO_TIMESTAMP
(= Long.MIN_VALUE
: ).
extractTimestamp
in interface TimestampAssigner<E>
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–2024 The Apache Software Foundation. All rights reserved.