Package cz.o2.proxima.core.time

Interface Summary

Interface	Description
PartitionedWatermarkEstimator	Watermark estimator wrapper for partitioned sources.
WatermarkEstimator	Estimates watermark according to incoming stream elements.
WatermarkEstimatorFactory	Factory creates watermark estimator instance.
WatermarkIdlePolicy	Policy defines behaviour how watermark should behave when streaming source is idle
WatermarkIdlePolicyFactory	Factory creates watermark idle policy instance.
WatermarkSupplier	Supplies the current watermark to clients.

Class Summary

Class	Description
AbstractWatermarkEstimator	The watermark estimator base class.
Watermarks