Module assembler 

Atomic coordinator-side assembly for distributed SQL reads.

Range workers never expose a client-visible stream directly. This module accepts only already fenced range payloads, verifies that every planned range has acknowledged cleanup, and then produces an immutable result.

Structs

AssemblerRow

One final-projection row emitted by a range worker during preparation.

DistributedReadBudget

Bounds coordinator-owned materialization. Spill is intentionally not implemented yet; a non-zero spill budget remains a declared upper bound, never permission for an unbounded temporary file.

ExactAggregatePartial

One group-local vector of exact accumulator states.

ExactAggregatePlan

Aggregate assembly whose worker states can be merged exactly.

GlobalOrder

One normalized global ORDER BY key. Values are produced by a worker’s closed descriptor; this type deliberately carries no executable SQL.

GlobalResultAssembler

Coordinator-owned atomic result assembler.

OrderedAggregateInput

One raw aggregate input. The worker has already evaluated the closed descriptor’s aggregate arguments; the coordinator only replays values.

OrderedAggregatePlan

Aggregate assembly that must replay globally ordered inputs to preserve local floating-point, DISTINCT, and string-aggregate semantics.

PreparedResult

Immutable result made visible only after every range has cleaned up.

PreparedResultStream

Reader for a PreparedResult. It has no transport/session dependency.

RangeAssemblerInput

All preparation payloads and terminal evidence for one planned range.

ResultPresentation

Final shaping shared by row and aggregate assembly.

RowMergePlan

Row-mode assembly for already projected range rows.

Enums

AssemblerTerminalStatus

Observable lifecycle state. A failed preparation never retains a prepared result and therefore cannot be opened as a row stream.

AssemblyPlan

Closed assembly mode selected by the SQL catalog/coordinator.

DistributedReadAssemblyError

Classified preparation failure. No variant carries partial SQL rows.

RangeAssemblerPayload

Typed payloads accepted from a completed range session.

RangeTerminal

Worker terminal state supplied by the transport coordinator. A completed range is usable only when it explicitly acknowledges cleanup.