Struct MergeWriteProbes 

pub struct MergeWriteProbes {
    pub stage_append_calls: Arc<AtomicU64>,
    pub stage_append_rows: Arc<AtomicU64>,
    pub stage_merge_insert_calls: Arc<AtomicU64>,
    pub stage_merge_insert_rows: Arc<AtomicU64>,
    pub create_vector_index_calls: Arc<AtomicU64>,
    pub scan_staged_combined_calls: Arc<AtomicU64>,
}

Per-operation staged-write counts, installed for a task via with_merge_write_probes. Lets a cost-budget test assert WHICH staged-write primitive an operation invokes — e.g. that an append-only fast-forward merge routes new rows through stage_append and does zero stage_merge_insert (the full-outer hash join). Counts the publish-path primitives only; merge-staging temp tables use append_or_create_batch, not these.

Fields

stage_append_calls: Arc<AtomicU64>

stage_append_rows: Arc<AtomicU64>

stage_merge_insert_calls: Arc<AtomicU64>

stage_merge_insert_rows: Arc<AtomicU64>

create_vector_index_calls: Arc<AtomicU64>

Inline vector-index (IVF) builds. The fast-forward adopt path defers index coverage to the reconciler, so an adopt merge must do 0 of these.

scan_staged_combined_calls: Arc<AtomicU64>

Times the merge materialized a staged delta into one in-memory batch (scan_staged_combined). The append path streams instead, so an append-only fast-forward merge must do 0 of these.

Implementations

impl MergeWriteProbes

pub fn stage_append_calls(&self) -> u64

pub fn stage_append_rows(&self) -> u64

pub fn stage_merge_insert_calls(&self) -> u64

pub fn stage_merge_insert_rows(&self) -> u64

pub fn create_vector_index_calls(&self) -> u64

pub fn scan_staged_combined_calls(&self) -> u64

Trait Implementations

impl Clone for MergeWriteProbes

fn clone(&self) -> MergeWriteProbes

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for MergeWriteProbes

fn default() -> MergeWriteProbes

Returns the “default value” for a type.