Struct RowCompletenessTracker 

pub struct RowCompletenessTracker { /* private fields */ }

Full-stream count of records in which every field is present.

Completeness of a record is not recoverable from per-column null totals: those say how many nulls exist, not whether two of them shared a row. One counter fed whole rows answers it exactly, at any scale and regardless of sampling.

Implementations

impl RowCompletenessTracker

pub fn observe(&mut self, had_null: bool)

Record one row. had_null is true when any of its fields was absent.

pub fn invalidate_completed_rows(&mut self)

A column appeared after rows had already been counted, so every row counted so far is missing it and none of them was complete after all.

pub fn observe_aligned_columns( &mut self, columns: &[&[String]], total_rows: usize, )

Count complete records across columns that are already row-aligned and hold every value, as the database and ad-hoc input paths do.

A row shorter than total_rows in some column is missing that field, which is the same as holding a null there — the reading StreamingColumnCollection::process_record gives ragged records.

pub fn merge(&mut self, other: &RowCompletenessTracker)

pub fn summary(&self) -> Option<RowCompletenessSummary>

Exact complete-record counts, or None when no rows were observed.

Trait Implementations

impl Clone for RowCompletenessTracker

fn clone(&self) -> RowCompletenessTracker

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RowCompletenessTracker

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

Formats the value using the given formatter.

impl Default for RowCompletenessTracker

fn default() -> RowCompletenessTracker

Returns the “default value” for a type.