cz.o2.proxima.core.storage.watermark

Interface Summary
Interface Description

GlobalWatermarkTracker
A tracker of global watermark progress among multiple (distributed) processes.
Class Summary
Class Description

GlobalWatermarkThroughputLimiter
A ThroughputLimiter that synchronizes progress of global watermark among distributed consumers.

Package cz.o2.proxima.core.storage.watermark