Struct ExecutionMetadata 

pub struct ExecutionMetadata {

    pub engine: Option<String>,
    pub recovery_events: Option<Vec<RecoveryEvent>>,
    pub rows_processed: usize,
    pub bytes_consumed: Option<u64>,
    pub columns_detected: usize,
    pub scan_time_ms: u128,
    pub throughput_rows_sec: Option<f64>,
    pub memory_peak_mb: Option<f64>,
    pub error_count: usize,
    pub ragged_row_count: usize,
    pub unterminated_quote: Option<bool>,
    pub source_exhausted: bool,
    pub truncation_reason: Option<TruncationReason>,
    pub sampling_applied: bool,
    pub sampling_ratio: Option<f64>,
    pub sampled_row_ranges: Option<Vec<[u64; 2]>>,
}

Metadata about the profiling execution.

Fields

engine: Option<String>

Engine or parser that actually produced the report.

recovery_events: Option<Vec<RecoveryEvent>>

Failed attempts and their retries. None means history was not recorded (e.g. a legacy report); Some([]) means no recovery occurred.

rows_processed: usize

Number of rows actually processed or analyzed.

bytes_consumed: Option<u64>

Number of bytes consumed from the source, if known.

columns_detected: usize

Number of columns detected in the data.

scan_time_ms: u128

Total execution time in milliseconds.

throughput_rows_sec: Option<f64>

Throughput in rows per second, auto-calculated when possible.

memory_peak_mb: Option<f64>

Peak process memory usage (resident set size) in megabytes observed during profiling, sampled at chunk/batch boundaries. Absent when the platform provided no reading or the input path does not track memory.

error_count: usize

Number of errors encountered during profiling.

ragged_row_count: usize

Number of data rows whose field count differed from the header’s.

These rows were recovered — extra trailing fields dropped, missing trailing fields padded to null — so profiling continued, but each one is a structural violation in the source. A nonzero value means the file did not parse cleanly even though a report was produced. Additive field: legacy documents without it deserialize as 0.

unterminated_quote: Option<bool>

Whether a CSV source ended inside a quoted field.

A quote that is never closed swallows every following row into the last field of one record, and the parser accepts it. true means the last record read may hold several source rows. Absent where it was not checked: non-CSV input, a scan that stopped before the end of the source, and reports written before 0.12.

source_exhausted: bool

Whether the entire source was consumed.

truncation_reason: Option<TruncationReason>

If the source was not exhausted, why processing stopped.

sampling_applied: bool

Whether sampling was applied.

sampling_ratio: Option<f64>

Ratio of rows analyzed to total rows when sampling is meaningful.

sampled_row_ranges: Option<Vec<[u64; 2]>>

Exact zero-based, half-open source row ranges selected for analysis, in source order. Absent when the input path does not record a selection; an empty list means a recorded selection of zero rows.

Implementations

impl ExecutionMetadata

pub fn new( rows_processed: usize, columns_detected: usize, scan_time_ms: u128, ) -> Self

Create new execution metadata with throughput calculated automatically.

pub fn with_engine(self, engine: impl Into<String>) -> Self

Record the engine or parser that actually produced the report.

pub fn with_sampling(self, ratio: f64) -> Self

Set sampling information.

pub fn with_source_exhausted(self, exhausted: bool) -> Self

Explicitly set whether the source was fully consumed.

pub fn with_truncation(self, reason: TruncationReason) -> Self

Mark the execution as truncated.

pub fn with_bytes_consumed(self, bytes: u64) -> Self

Set the number of bytes consumed from the source.

pub fn with_error_count(self, count: usize) -> Self

Set the error count.

pub fn with_ragged_row_count(self, count: usize) -> Self

Set the count of ragged rows (field count != header field count).

pub fn with_unterminated_quote(self, ended_inside_quotes: bool) -> Self

Record whether a checked CSV source ended inside a quoted field.

pub fn with_memory_peak_mb(self, mb: f64) -> Self

Set peak memory usage.

Trait Implementations

impl Clone for ExecutionMetadata

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 ExecutionMetadata

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ExecutionMetadata

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl JsonSchema for ExecutionMetadata

fn schema_name() -> Cow<'static, str>

The name of the generated JSON Schema.

fn schema_id() -> Cow<'static, str>

Returns a string that uniquely identifies the schema produced by this type.

fn json_schema(generator: &mut SchemaGenerator) -> Schema

Generates a JSON Schema for this type.

fn inline_schema() -> bool

Whether JSON Schemas generated for this type should be included directly in parent schemas, rather than being re-used where possible using the $ref keyword.

impl Serialize for ExecutionMetadata

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.