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