Struct StreamingFieldProcessor 

pub struct StreamingFieldProcessor { /* private fields */ }

Streaming field processor with constant memory usage

Implementations

impl StreamingFieldProcessor

pub fn new() -> Self

Create a new streaming field processor

pub fn with_config(config: StreamingFieldProcessorConfig) -> Self

Create a new streaming field processor with custom configuration

pub fn process_record_streaming<F>( &mut self, allocation: PartialAllocationInfo, requested_fields: &HashSet<AllocationField>, processor: F, ) -> Result<(), BinaryExportError>

where F: FnMut(&OptimizedRecord) -> Result<(), BinaryExportError>,

Process a single record with streaming (constant memory)

pub fn process_records_streaming<F>( &mut self, allocations: Vec<PartialAllocationInfo>, requested_fields: &HashSet<AllocationField>, processor: F, ) -> Result<(), BinaryExportError>

where F: FnMut(&OptimizedRecord) -> Result<(), BinaryExportError>,

Process multiple records in streaming fashion

pub fn get_or_format_field( &mut self, cache_key: &str, field: &AllocationField, allocation: &PartialAllocationInfo, ) -> Result<Option<String>, BinaryExportError>

Get a cached field value or format and cache it

pub fn get_stats(&self) -> &StreamingFieldProcessorStats

Get current statistics

pub fn reset_stats(&mut self)

Reset statistics

pub fn clear_cache(&mut self)

Clear all caches

pub fn cache_size(&self) -> usize

Get current cache size

pub fn memory_usage(&self) -> usize

Get current memory usage

Trait Implementations

impl Default for StreamingFieldProcessor

fn default() -> Self

Returns the “default value” for a type.