org.apache.flink.streaming.api.functions

Class AscendingTimestampExtractor<T>

java.lang.Object

org.apache.flink.streaming.api.functions.timestamps.AscendingTimestampExtractor<T>

org.apache.flink.streaming.api.functions.AscendingTimestampExtractor<T>

Type Parameters:

T - The type of the elements that this function can extract timestamps from

All Implemented Interfaces:

Serializable, TimestampAssigner<T>, Function, AssignerWithPeriodicWatermarks<T>

Deprecated.

Extend AscendingTimestampExtractor instead.

@PublicEvolving
 @Deprecated
public abstract class AscendingTimestampExtractor<T>
extends AscendingTimestampExtractor<T>

A timestamp assigner and watermark generator for streams where timestamps are monotonously ascending. In this case, the local watermarks for the streams are easy to generate, because they strictly follow the timestamps.

Note: This is just a deprecated stub class. The actual code for this has moved to AscendingTimestampExtractor.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.streaming.api.functions.timestamps.AscendingTimestampExtractor

AscendingTimestampExtractor.FailingHandler, AscendingTimestampExtractor.IgnoringHandler, AscendingTimestampExtractor.LoggingHandler, AscendingTimestampExtractor.MonotonyViolationHandler

Field Summary

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

NO_TIMESTAMP

Constructor Summary

Constructors

Constructor and Description
AscendingTimestampExtractor() Deprecated.

Method Summary

Methods inherited from class org.apache.flink.streaming.api.functions.timestamps.AscendingTimestampExtractor

extractAscendingTimestamp, extractTimestamp, getCurrentWatermark, withViolationHandler

Methods inherited from class java.lang.Object

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

Constructor Detail

AscendingTimestampExtractor

public AscendingTimestampExtractor()

Deprecated.