Module breaker_executor 

Compiled stateful pipeline bridge — wires pipeline breakers to Ring 1 operators.

When a query plan contains stateful operators (aggregation, sort, join), the compiler splits execution into multiple compiled segments separated by breaker boundaries. Each BreakerExecutor handles the Ring 1 operator at a pipeline boundary, consuming output from an upstream compiled segment and producing input for a downstream one.

Architecture

   Compiled Segment 1        BreakerExecutor        Compiled Segment 2
  (Filter + Project)       (Ring 1 Operator)       (Output Projection)
  ┌──────────────────┐    ┌──────────────────┐    ┌──────────────────┐
  │ fn(in, out) → u8 │──► │  process_batch   │──► │ fn(in, out) → u8 │
  └──────────────────┘    └──────────────────┘    └──────────────────┘
       PipelineBridge          State Store          PipelineBridge

Structs

BreakerExecutor

Executes a Ring 1 stateful operator at a pipeline boundary.

CompiledQueryGraph

A graph of compiled segments connected by Ring 1 operators.

Traits

Ring1Operator

A Ring 1 operator that processes batches at a pipeline boundary.