Struct StreamingProgress 

pub struct StreamingProgress {
    pub total_rows: Option<u64>,
    pub processed_rows: u64,
    pub batches_processed: u64,
    pub start_time: Instant,
}

Progress tracking for streaming operations

Fields

total_rows: Option<u64>

processed_rows: u64

batches_processed: u64

start_time: Instant

Implementations

impl StreamingProgress

pub fn new(total_rows: Option<u64>) -> Self

pub fn update(&mut self, batch_size: u64)

pub fn percentage(&self) -> Option<f64>

pub fn elapsed(&self) -> Duration

pub fn estimated_total_time(&self) -> Option<Duration>

pub fn rows_per_second(&self) -> f64