Package org.apache.flink.streaming.api.functions.timestamps

Class AscendingTimestampExtractor<T>

java.lang.Object

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

Type Parameters:

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

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.eventtime.TimestampAssigner<T>, org.apache.flink.api.common.eventtime.TimestampAssignerSupplier<T>, org.apache.flink.api.common.eventtime.WatermarkGeneratorSupplier<T>, org.apache.flink.api.common.eventtime.WatermarkStrategy<T>, org.apache.flink.streaming.runtime.operators.util.WatermarkStrategyWithPeriodicWatermarks<T>

@Deprecated
@PublicEvolving
public abstract class AscendingTimestampExtractor<T>
extends Object
implements org.apache.flink.streaming.runtime.operators.util.WatermarkStrategyWithPeriodicWatermarks<T>

Deprecated.

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.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AscendingTimestampExtractor.FailingHandler	Deprecated. Handler that fails the program when timestamp monotony is violated.
static class	AscendingTimestampExtractor.IgnoringHandler	Deprecated. Handler that does nothing when timestamp monotony is violated.
static class	AscendingTimestampExtractor.LoggingHandler	Deprecated. Handler that only logs violations of timestamp monotony, on WARN log level.
static interface	AscendingTimestampExtractor.MonotonyViolationHandler	Deprecated. Interface for handlers that handle violations of the monotonous ascending timestamps property.

Nested classes/interfaces inherited from interface org.apache.flink.api.common.eventtime.TimestampAssignerSupplier

org.apache.flink.api.common.eventtime.TimestampAssignerSupplier.Context, org.apache.flink.api.common.eventtime.TimestampAssignerSupplier.SupplierFromSerializableTimestampAssigner<T extends Object>

Nested classes/interfaces inherited from interface org.apache.flink.api.common.eventtime.WatermarkGeneratorSupplier

org.apache.flink.api.common.eventtime.WatermarkGeneratorSupplier.Context

Field Summary

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

NO_TIMESTAMP

Constructor Summary

Constructors

Constructor	Description
AscendingTimestampExtractor()	Deprecated.

Method Summary

Modifier and Type	Method	Description
abstract long	extractAscendingTimestamp(T element)	Deprecated. Extracts the timestamp from the given element.
long	extractTimestamp(T element, long elementPrevTimestamp)	Deprecated.
org.apache.flink.streaming.api.watermark.Watermark	getCurrentWatermark()	Deprecated.
AscendingTimestampExtractor<T>	withViolationHandler(AscendingTimestampExtractor.MonotonyViolationHandler handler)	Deprecated. Sets the handler for violations to the ascending timestamp order.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.api.common.eventtime.WatermarkStrategy

getAlignmentParameters, withIdleness, withTimestampAssigner, withTimestampAssigner, withWatermarkAlignment, withWatermarkAlignment

Methods inherited from interface org.apache.flink.streaming.runtime.operators.util.WatermarkStrategyWithPeriodicWatermarks

createTimestampAssigner, createWatermarkGenerator

Constructor Detail

AscendingTimestampExtractor

public AscendingTimestampExtractor()

Deprecated.

Method Detail

extractAscendingTimestamp

public abstract long extractAscendingTimestamp(T element)

Deprecated.

Extracts the timestamp from the given element. The timestamp must be monotonically increasing.

Parameters:

element - The element that the timestamp is extracted from.

Returns:

The new timestamp.

withViolationHandler

public AscendingTimestampExtractor<T> withViolationHandler(AscendingTimestampExtractor.MonotonyViolationHandler handler)

Deprecated.

Sets the handler for violations to the ascending timestamp order.

Parameters:

handler - The violation handler to use.

Returns:

This extractor.

extractTimestamp

public final long extractTimestamp(T element,
                                   long elementPrevTimestamp)

Deprecated.

Specified by:

extractTimestamp in interface org.apache.flink.api.common.eventtime.TimestampAssigner<T>

getCurrentWatermark

public final org.apache.flink.streaming.api.watermark.Watermark getCurrentWatermark()

Deprecated.

Specified by:

getCurrentWatermark in interface org.apache.flink.streaming.runtime.operators.util.WatermarkStrategyWithPeriodicWatermarks<T>