Interface TimestampAssigner<T>

    • Field Summary

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

        NO_TIMESTAMP
    • 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:
        extractTimestamp in interface org.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.