MultiOriginWatermarkProcessor.hpp File Reference

#include <map>
#include <memory>
#include <mutex>

Include dependency graph for MultiOriginWatermarkProcessor.hpp:

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

Classes
class	NES::Windowing::MultiOriginWatermarkProcessor
	The watermark processor receives watermark barriers and provides the current watermark across multiple origins. The watermark processor guarantees strict serializable watermark updates. Thus, a watermark processor is only executed if all preceding updates have been processed. Consequently, the watermark processor expects a exactly once delivery on the input channel. More...

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

Typedefs
using	NES::WatermarkTs = uint64_t
using	NES::OriginId = uint64_t
using	NES::SequenceNumber = uint64_t
using	NES::Windowing::MultiOriginWatermarkProcessorPtr = std::unique_ptr< MultiOriginWatermarkProcessor >