Rindle docs and package mapSkip to main content

PUSH_CHUNK_ROWS

Constant PUSH_CHUNK_ROWS 

Source
pub const PUSH_CHUNK_ROWS: usize = 1024;
Expand description

Upper bound on one streamed fan-out chunk, in captured rows (CLUSTER-INCREMENTAL-FANOUT-DESIGN.md §4.2). Bounds the writer’s transient capture buffer — and, on the live replica, the per-worker transient output and the cross-thread message — to O(chunk) rather than O(txn); a txn ≤ this size streams as a single chunk. Owned by the apply plane because the between-statement drain (ApplyTxn::maybe_pump) is what enforces the writer-side bound, with or without a derivation pool on the other end.