Struct ColumnarStats 

pub struct ColumnarStats {

    pub columnar_hits: AtomicU64,
    pub columnar_misses: AtomicU64,
    pub columnar_typed_hits: AtomicU64,
    pub selection_attached: AtomicU64,
    pub selection_materialized: AtomicU64,
    pub selection_pushed: AtomicU64,
    pub column_block_hits: AtomicU64,
    pub multiplicity_expanded: AtomicU64,
    pub spill_rows: AtomicU64,
    pub spill_bytes: AtomicU64,
    pub spill_runs: AtomicU64,
    pub batch_outlets: AtomicU64,
    pub columnar_b_path_hits: AtomicU64,
    pub columnar_wasted_builds: AtomicU64,
    /* private fields */
}

Query-level columnar fast-path counters (observability).

Shared via Arc with the chunks produced by source operators; every DataChunk::evaluate_expression call records a hit (columnar batch path succeeded) or a miss (fell back to per-row evaluation). The miss rate exposes how much of the flat-column promise is actually kept.

columnar_typed_hits additionally counts evaluations served by the typed batch fast path (raw Vec<i64>/Vec<f64>/Vec<i32> buffers). Selection-vector counters record how often chunks are handed downstream with a selection attached vs. materialized at a boundary.

Fields

columnar_hits: AtomicU64

columnar_misses: AtomicU64

columnar_typed_hits: AtomicU64

Evaluations served by the typed batch fast path.

selection_attached: AtomicU64

Chunks handed downstream with a selection vector attached.

selection_materialized: AtomicU64

Chunks materialized at a selection boundary.

selection_pushed: AtomicU64

evaluations served by the selection-aware visible-row fast path (selection vector consumed without materializing).

column_block_hits: AtomicU64

Chunks produced by a source via the storage column-block path (A1).

multiplicity_expanded: AtomicU64

Logical rows produced by expanding DataChunk::multiplicity at opaque boundaries (normalize_for_opaque). Compared against stored rows it yields the expanded/stored ratio for PROFILE observability.

spill_rows: AtomicU64

Rows written to spill runs (all operators, incl. terminal collector).

spill_bytes: AtomicU64

Bytes written to spill runs (on-disk file sizes).

spill_runs: AtomicU64

Number of spill runs finalized.

batch_outlets: AtomicU64

Chunks emitted through the batch-slice outlet path.

columnar_b_path_hits: AtomicU64

Expressions served by the typed columnar fast path on the compiled (project/filter) hot path — i.e. the compiled-over-rows path was bypassed because the chunk carried a usable typed layout. Distinct from columnar_typed_hits, which counts the scalar chunk evaluator.

columnar_wasted_builds: AtomicU64

Typed layouts built by a producer that were dropped before any downstream consumer read them (take_rows_for_reuse, join build consumption). A high count means typed columns were built in vain.

Implementations

impl ColumnarStats

pub fn new() -> Self

pub fn record_hit(&self)

pub fn record_miss(&self)

pub fn record_typed_hit(&self)

Record an evaluation served by the typed batch fast path.

pub fn record_b_path_hit(&self)

Record an expression served by the typed columnar fast path on the compiled (project/filter) hot path.

pub fn record_wasted_build(&self)

Record a typed layout dropped before any downstream consumer read it.

pub fn record_selection_attached(&self)

Record a chunk handed downstream with a selection vector.

pub fn record_selection_materialized(&self)

Record a chunk materialized at a selection boundary.

pub fn record_selection_materialized_by(&self, op: &'static str)

Record a chunk materialized at a named operator boundary.

The hot path is lock-free: it bumps the global counter and, if op belongs to the closed SELECTION_BOUNDARY_OPS enumeration, the matching per-operator atomic slot. Unknown labels still count toward the global materialization total but are not attributed per operator.

pub fn record_selection_pushed(&self)

record an evaluation served by the selection-aware visible-row fast path (selection consumed in place, upstream chunk untouched).

pub fn materialized_by_operator(&self) -> HashMap<&'static str, u64>

materialization sites, attributed per operator.

pub fn record_column_block_hit(&self)

Record a chunk produced via the storage column-block path (A1).

pub fn record_multiplicity_expanded(&self, n: u64)

Record n logical rows produced by multiplicity expansion.

pub fn record_spill(&self, rows: u64, bytes: u64)

Record one finalized spill run.

pub fn record_batch_outlet(&self)

Record one chunk emitted through the batch-slice outlet path.

pub fn record_spill_with_runs(&self, rows: u64, bytes: u64, runs: u64)

Record aggregated spill output covering runs finalized runs.

Terminal collector paths finalize N runs but report once; passing the run count keeps spill_runs exact instead of undercounting to 1.

pub fn hit_rate(&self) -> f64

Fraction of evaluation calls that hit the columnar fast path. Returns 1.0 when nothing was evaluated (vacuous).

pub fn typed_hit_rate(&self) -> f64

Fraction of evaluations served by the typed batch fast path.

pub fn selection_passthrough_rate(&self) -> f64

Selection passthrough rate: attached / (attached + materialized). 1.0 means every selected chunk reached its consumer without materializing.

Trait Implementations

impl Debug for ColumnarStats

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ColumnarStats

fn default() -> Self

Returns the “default value” for a type.