Interface | Description |
---|---|
AscendingTimestampExtractor.MonotonyViolationHandler |
Interface for handlers that handle violations of the monotonous ascending timestamps
property.
|
AssignerWithPeriodicWatermarks<T> |
The
AssignerWithPeriodicWatermarks assigns event time timestamps to elements,
and generates low watermarks that signal event time progress within the stream. |
AssignerWithPunctuatedWatermarks<T> |
The
AssignerWithPunctuatedWatermarks assigns event time timestamps to elements,
and generates low watermarks that signal event time progress within the stream. |
TimestampAssigner<T> |
A
TimestampAssigner assigns event time timestamps to elements. |
TimestampExtractor<T> | Deprecated
This class has been replaced by
AssignerWithPeriodicWatermarks and
AssignerWithPunctuatedWatermarks |
Class | Description |
---|---|
AscendingTimestampExtractor<T> |
A timestamp assigner and watermark generator for streams where timestamps are monotonously
ascending.
|
AscendingTimestampExtractor.FailingHandler |
Handler that fails the program when timestamp monotony is violated.
|
AscendingTimestampExtractor.IgnoringHandler |
Handler that does nothing when timestamp monotony is violated.
|
AscendingTimestampExtractor.LoggingHandler |
Handler that only logs violations of timestamp monotony, on WARN log level.
|
IngestionTimeExtractor<T> |
A timestamp assigner that assigns timestamps based on the machine's wall clock.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.