Struct StreamingColumnCollection 

pub struct StreamingColumnCollection { /* private fields */ }

Implementations

impl StreamingColumnCollection

pub fn new() -> Self

pub fn memory_limit(limit_mb: usize) -> Self

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

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

where I: IntoIterator<Item = String>,

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.