Struct StreamingColumnCollection 

pub struct StreamingColumnCollection { /* private fields */ }

Implementations

impl StreamingColumnCollection

pub fn new() -> Self

pub fn memory_limit(limit_mb: usize) -> Self

pub fn with_semantic_hints(self, hints: &SemanticHints) -> Self

Configure value-driven semantic hints before records are processed.

pub fn init_columns(&mut self, headers: &[String])

pub fn init_column_with_missing(&mut self, header: &str, prior_rows: usize)

Add a column discovered after prior_rows records have already passed.

JSON objects may introduce keys at any point in a stream. Those earlier objects are missing the new key, so the column must start with matching total/null counters rather than looking shorter and more complete than the dataset.

pub fn process_record<I>(&mut self, headers: &[String], values: I)

where I: IntoIterator<Item = String>,

pub fn row_duplicate_summary(&self) -> Option<RowDuplicateSummary>

Full-stream row-duplicate counts, or None when no rows were seen.

pub fn semantic_hint_bindings(&self) -> Vec<SemanticHintBinding>

Exact value-driven semantic-hint evidence over every processed record.

pub fn get_column_stats( &self, column_name: &str, ) -> Option<&StreamingStatistics>

pub fn column_names(&self) -> Vec<String>

pub fn memory_usage_bytes(&self) -> usize

pub fn is_memory_pressure(&self) -> bool

pub fn reduce_memory_usage(&mut self)

pub fn column_type_fingerprint(&self) -> u64

Fingerprint of each column’s currently inferred data type.

Returns a u64 hash suitable for cheap comparison in a schema stability tracker.

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

Trait Implementations

impl Default for StreamingColumnCollection

fn default() -> Self

Returns the “default value” for a type.