Interface TimestampAssigner<T>
-
- Type Parameters:
T- The type of the elements to which this assigner assigns timestamps.
- All Superinterfaces:
org.apache.flink.api.common.functions.Function,Serializable,org.apache.flink.api.common.eventtime.TimestampAssigner<T>
- All Known Subinterfaces:
AssignerWithPeriodicWatermarks<T>,AssignerWithPunctuatedWatermarks<T>
- All Known Implementing Classes:
AscendingTimestampExtractor,AscendingTimestampExtractor,BoundedOutOfOrdernessTimestampExtractor,IngestionTimeExtractor
@Deprecated public interface TimestampAssigner<T> extends org.apache.flink.api.common.eventtime.TimestampAssigner<T>, org.apache.flink.api.common.functions.Function
Deprecated.useTimestampAssignerATimestampAssignerassigns 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).
-
-
Method Summary
All Methods Instance Methods Abstract Methods Deprecated Methods Modifier and Type Method Description longextractTimestamp(T element, long recordTimestamp)Deprecated.Assigns a timestamp to an element, in milliseconds since the Epoch.
-
-
-
Method Detail
-
extractTimestamp
long extractTimestamp(T element, long recordTimestamp)
Deprecated.Assigns a timestamp to an element, in milliseconds since the Epoch.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
Long.MIN_VALUE.- Specified by:
extractTimestampin interfaceorg.apache.flink.api.common.eventtime.TimestampAssigner<T>- Parameters:
element- The element that the timestamp will be assigned to.recordTimestamp- The previous internal timestamp of the element, or a negative value, if no timestamp has been assigned yet.- Returns:
- The new timestamp.
-
-