feat: multi-connector ingest (Prometheus + VictoriaMetrics) + pane-based sliding window#230

Merged

milindsrivastava1997 merged 20 commits intomainfrom

pr/C-multi-connector-pane-sliding-window

Apr 6, 2026

Commits on Mar 31, 2026

Add standalone precompute engine to replace Arroyo streaming pipeline

zzylol
and
claude
committed
Wire up DatasketchesKLL in accumulator factory and add E2E test

zzylol
and
claude
committed
Add 1000-sample batch latency test to E2E precompute test

zzylol
and
claude
committed
Add 10M-sample throughput test to E2E precompute test

zzylol
and
claude
committed
update
zzylol
committed
Fix sliding window aggregation: feed samples into all overlapping windows

zzylol
and
claude
committed
fix: remove duplicate [[bin]] entries in Cargo.toml from rebase merge

zzylol
and
claude
committed
style: apply cargo fmt

zzylol
and
claude
committed
fix: use std::io::Error::other per clippy lint

zzylol
and
claude
committed
fix: remove unnecessary cast per clippy lint

zzylol
and
claude
committed
Add standalone precompute engine to replace Arroyo streaming pipeline

zzylol
and
claude
committed
Wire up DatasketchesKLL in accumulator factory and add E2E test

zzylol
and
claude
committed
Add late data handling for closed windows and precompute engine design doc

zzylol
and
claude
committed
Minor wording fix in precompute engine design doc

zzylol
and
claude
committed
Clarify single-machine multi-threaded architecture in design doc

zzylol
and
claude
committed
Add multi-connector ingest support (Prometheus + VictoriaMetrics)

zzylol
and
claude
committed
Run cargo fmt

zzylol
and
claude
committed
Add pane-based incremental sliding window computation

zzylol
and
claude
committed

Commits on Apr 1, 2026