wegamekinglc / calc-flow / 35475219344

93%

push

github

perf: batch stream_join output emission (DAL-286) (#298)

Replace the bounded inner stream join's per-row output emission with one
multi-row record per input batch, split into edge-budget-sized messages that
mirror the window operator's chunking path. Row order, match semantics,
watermark eviction, and checkpoint/restore are unchanged; an over-budget row
now fails before any emission. Real-runner throughput improves about 5x at
20k rows and the 10M-row tier fits the benchmark suite budget.

346 of 373 new or added lines in 1 file covered. (92.76%)

104896 of 112696 relevant lines covered (93.08%)

69317.7 hits per line