@Public public final class RecordTimestampAssigner<E> extends Object implements TimestampAssigner<E>
TimestampAssignerthat 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.
|Constructor and Description|
|Modifier and Type||Method and Description|
Assigns a timestamp to an element, in milliseconds since the Epoch.
public long extractTimestamp(E 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
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.