Enum ProgressEvent 

pub enum ProgressEvent {
    Started {
        estimated_total_rows: Option<usize>,
        estimated_total_bytes: Option<u64>,
    },
    ChunkProcessed {
        rows_processed: usize,
        bytes_consumed: u64,
        elapsed: Duration,
        processing_speed: f64,
        percentage: Option<f64>,
    },
    SchemaDetected {
        column_names: Vec<String>,
    },
    Finished {
        total_rows: usize,
        total_bytes: u64,
        elapsed: Duration,
        truncated: bool,
    },
    Warning {
        message: String,
    },
}

Structured progress events emitted by profiling engines.

Variants

Started

Profiling has started. Emitted once before any data is processed.

Fields

estimated_total_rows: Option<usize>

estimated_total_bytes: Option<u64>

ChunkProcessed

A chunk of rows has been processed.

Fields

rows_processed: usize

bytes_consumed: u64

elapsed: Duration

processing_speed: f64

percentage: Option<f64>

SchemaDetected

Column schema has been detected: emitted after the first chunk, and again with the full list whenever a later column joins (an async JSON key first seen after the first chunk). Each list extends the last.

Fields

column_names: Vec<String>

Finished

Profiling has finished (successfully or via early stop).

Fields

total_rows: usize

total_bytes: u64

elapsed: Duration

truncated: bool

Warning

A non-fatal warning occurred during processing.

Fields

message: String

Trait Implementations

impl Clone for ProgressEvent

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ProgressEvent

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

Formats the value using the given formatter.