Struct IngestStats 

pub struct IngestStats {
    pub operation: String,
    pub rows: u64,
    pub elapsed_ms: u64,
    pub bytes_read: u64,
    pub bytes_stored: u64,
    pub schema_inference_ms: Option<u64>,
    pub table: String,
    pub file_format: Option<String>,
    pub warning: Option<String>,
    pub schema_changed: bool,
}

Telemetry for data ingest operations (load_data, load_file, one-shot ingest).

The to_json() method enriches the base fields with computed throughput: rows_per_sec, ingest_throughput_mb_sec, and compression_ratio.

Fields

operation: String

rows: u64

Rows written to the target table by this call.

For replace / append this matches the file row count. For merge it’s the count returned by the post-DELETE INSERT — treat as “rows written to target” rather than “rows in input”.

elapsed_ms: u64

bytes_read: u64

Raw input size (string length for inline data, file size for file ingest).

bytes_stored: u64

On-disk Hyper storage consumed. Zero when not measured.

schema_inference_ms: Option<u64>

table: String

file_format: Option<String>

warning: Option<String>

Advisory warning for the LLM (e.g. “use load_file for large inline data”).

schema_changed: bool

true when this ingest changed the target’s column set — today, only mode = "merge" can flip this on (via auto- ALTER TABLE ADD COLUMN). Drives whether the server fires a resource-list-changed notification post-call. Default false so non-merge paths don’t have to think about it.

Implementations

impl IngestStats

pub fn rows_per_sec(&self) -> u64

Rows ingested per second. Returns rows directly if elapsed is zero to avoid division by zero.

pub fn ingest_throughput_mb_sec(&self) -> f64

Input data throughput in MB/s (decimal megabytes).

pub fn compression_ratio(&self) -> f64

Ratio of stored bytes to input bytes. Values < 1.0 indicate Hyper’s columnar compression is smaller than the source format.

pub fn to_json(&self) -> Value

Serialize to JSON with derived throughput fields merged in.

Trait Implementations

impl Clone for IngestStats

fn clone(&self) -> IngestStats

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for IngestStats

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

Formats the value using the given formatter.

impl Serialize for IngestStats

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

where __S: Serializer,

Serialize this value into the given Serde serializer.