org.apache.flink.streaming.api.functions.python.eventtime

Class CustomTimestampAssigner<T>

java.lang.Object

org.apache.flink.streaming.api.functions.python.eventtime.CustomTimestampAssigner<T>

All Implemented Interfaces:

Serializable, SerializableTimestampAssigner<Tuple2<T,Long>>, TimestampAssigner<Tuple2<T,Long>>

@Internal
public class CustomTimestampAssigner<T>
extends Object
implements SerializableTimestampAssigner<Tuple2<T,Long>>

TimestampAssigner which extracts timestamp from the second field of the input element.

See Also:

Serialized Form

Field Summary

Fields inherited from interface org.apache.flink.api.common.eventtime.TimestampAssigner

NO_TIMESTAMP

Constructor Summary

Constructors

Constructor and Description
CustomTimestampAssigner()

Method Summary

Modifier and Type	Method and Description
long	extractTimestamp(Tuple2<T,Long> element, long recordTimestamp) Assigns a timestamp to an element, in milliseconds since the Epoch.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CustomTimestampAssigner

public CustomTimestampAssigner()

Method Detail

extractTimestamp

public long extractTimestamp(Tuple2<T,Long> element,
                             long recordTimestamp)

Description copied from interface: TimestampAssigner

Assigns a timestamp to an element, in milliseconds since the Epoch. This is independent of any particular time zone or calendar.

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: ).

Specified by:

extractTimestamp in interface TimestampAssigner<Tuple2<T,Long>>

Parameters:

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.

Returns:

The new timestamp.