diff options
| author | yumkam7 <[email protected]> | 2025-12-04 16:47:43 +0300 |
|---|---|---|
| committer | yumkam7 <[email protected]> | 2025-12-04 17:06:50 +0300 |
| commit | d020a6d7b783c9ef187887eb294ed4c0a0de9244 (patch) | |
| tree | 5ec6adb2a6d13656b9f6cff807519c136cdf980d /library/cpp/monlib/encode/prometheus/prometheus_decoder.cpp | |
| parent | 2cf18d3189ca7cdac1ddbf73b5fc5aa3322a9f21 (diff) | |
multihopping/HoppingWindow: add unlimited/far/sparse windows
Design notes:
Cтарый код: мержит предагрегаты по циклическому буферу с размером Buckets.size() \>= IntervalHopCount, буфер начинается со времени HopIndex, и ему соответствует индекс в буфере HopIndex % Buckets.size()
Новый код: добавляет ещё ordered map для окон в далёком будущем. Для циклического буфера добавляет индекс последнего валидного хопа (в буфере, события в FutureEvents не учитываются)
Цикл расчёта разбит на два этапа: проход по циклическому буферу (как раньше), потом такой же проход по FutureEvents. При проходе через FutureEvents мы можем прыгать через пустые интервалы
multihopping: add save/load EarlyEvents
multihopping: infinite window support
minor simplification
minor refactoring
micro-optimizations
review fix: revert still-useful part of revert
Revert "\\] Watermarks: Hopping: close windows by events too"
This reverts commit 35ce54117b1bd4d637f7f2f4a666901c8bb6bf8a, reversing
changes made to dc203874326c0cb4d600bf3e0d658a694162b1ab.
Additional changes: spaces
commit_hash:081ea321f57e765910d16299b99e3087d1bcfdb2
Diffstat (limited to 'library/cpp/monlib/encode/prometheus/prometheus_decoder.cpp')
0 files changed, 0 insertions, 0 deletions