WatermarkProcessor.hpp File Reference

#include <atomic>
#include <mutex>
#include <queue>

Include dependency graph for WatermarkProcessor.hpp:

This graph shows which files directly or indirectly include this file:

Classes
class	NES::Windowing::WatermarkProcessor
	This class implements a watermark processor for a single origin. It processes all watermark updates from one specific origin and applies all updates in sequential order. @assumptions This watermark processor assumes strictly monotonic update sequence numbers. To handle out of order processing, it stores in flight updates in a transaction log. More...

Namespaces
	NES
	This exception represents a network error.
	NES::Windowing