Package cz.o2.proxima.direct.core.time

Interface Summary

Interface	Description
TimestampSupplier

Class Summary

Class	Description
BoundedOutOfOrdernessWatermarkEstimator	This estimators generates watermarks assuming that elements arrive out of order, but only to a certain degree defined by configuration: watermark.max-out-of-orderness.
BoundedOutOfOrdernessWatermarkEstimator.Builder	Builder of the BoundedOutOfOrdernessWatermarkEstimator.
BoundedOutOfOrdernessWatermarkEstimator.Factory	Creates an instance of BoundedOutOfOrdernessWatermarkEstimator.
MinimalPartitionWatermarkEstimator	Watermark estimator wrapper for partitioned sources.
NotProgressingWatermarkIdlePolicy	Idle policy doesn't progress watermark on idle.
NotProgressingWatermarkIdlePolicy.Factory
ProcessingTimeShiftingWatermarkIdlePolicy	Idle policy that shifts watermark by the amount of processing time elapsed in the idle state.
ProcessingTimeShiftingWatermarkIdlePolicy.Factory
ProcessingTimeWatermarkEstimator	Estimates watermark as processing time.
ProcessingTimeWatermarkEstimator.Builder	Builder of the ProcessingTimeWatermarkEstimator.
ProcessingTimeWatermarkEstimator.Factory	Creates an instance of ProcessingTimeWatermarkEstimator.
SkewedProcessingTimeIdlePolicy	Policy returns skewed (delayed) processing time when source is idle.
SkewedProcessingTimeIdlePolicy.Factory
UnboundedOutOfOrdernessWatermarkEstimator	Estimator of watermark based on timestamps of flowing elements.
UnboundedOutOfOrdernessWatermarkEstimator.Builder	Builder of the UnboundedOutOfOrdernessWatermarkEstimator.
UnboundedOutOfOrdernessWatermarkEstimator.Factory
WatermarkConfiguration	Watermark configuration