Struct ProfileBoard 

pub struct ProfileBoard {
    pub total_rows: AtomicU64,
    pub total_time_us: AtomicU64,
    pub parallel_wall_time_us: AtomicU64,
    pub parallel_work_time_us: AtomicU64,
    pub parallel_workers: AtomicUsize,
    pub parallel_buffered_chunks_peak: AtomicUsize,
    pub parallel_buffered_bytes_peak: AtomicUsize,
    /* private fields */
}

Lock-free profile store for hot-path operator timing and row-count updates.

Uses RwLock for structural operations (first-access entry creation) and AtomicU64 counters so that per-advance increments never block.

Design:

• register_operator() — called during open(), pre-creates entries
• record_timing() / record_rows() — lock-free fast path
• flush_to_collector() — aggregate into a ProfileCollector at end

Fields

total_rows: AtomicU64

total_time_us: AtomicU64

parallel_wall_time_us: AtomicU64

parallel_work_time_us: AtomicU64

parallel_workers: AtomicUsize

parallel_buffered_chunks_peak: AtomicUsize

parallel_buffered_bytes_peak: AtomicUsize

Implementations

impl ProfileBoard

pub fn new() -> Self

pub fn record_start(&self)

pub fn record_end(&self)

pub fn register_operator(&self, profile: &OperatorProfile) -> Arc<ProfileEntry>

Register (or update) a per-operator profile entry from a snapshot.

Called during open() to pre-populate entries so the hot-path access in advance() never needs to write-lock.

pub fn get_entry(&self, key: &OperatorProfileKey) -> Option<Arc<ProfileEntry>>

Find an entry by key (read-lock, hot-path friendly).

pub fn flush_to_collector(&self) -> ProfileCollector

Aggregate all entries into a ProfileCollector for EXPLAIN output.

Trait Implementations

impl Debug for ProfileBoard

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

Formats the value using the given formatter.

impl Default for ProfileBoard

fn default() -> Self

Returns the “default value” for a type.