Struct DeltaReadMetricsSnapshot 

pub struct DeltaReadMetricsSnapshot {

    pub snapshot_version: u64,
    pub reader_backend: DeltaReaderBackend,
    pub scan_metadata_exhausted: Option<bool>,
    pub scan_partitions_planned: u64,
    pub files_planned: u64,
    pub files_filtered_during_planning: Option<u64>,
    pub estimated_rows: Option<u64>,
    pub estimated_bytes: Option<u64>,
    pub scan_partitions_started: u64,
    pub scan_partitions_completed: u64,
    pub files_started: u64,
    pub files_completed: u64,
    pub batches_produced: u64,
    pub rows_produced: u64,
    pub deletion_vector_payloads_loaded: u64,
    pub deletion_vectors_applied: u64,
    pub deletion_vector_rows_deleted: u64,
    pub deletion_vector_failures: u64,
    pub deletion_vector_rejections: u64,
    pub parquet_data_file_range_get_operations: Option<u64>,
    pub parquet_data_file_full_get_operations: Option<u64>,
    pub parquet_data_file_bytes_received: Option<u64>,
    pub parquet_data_file_opened_bytes: Option<u64>,
}

Immutable point-in-time metrics for one Delta scan.

Fields

snapshot_version: u64

Delta snapshot version selected for the scan.

reader_backend: DeltaReaderBackend

Data-file reader backend selected for the scan.

scan_metadata_exhausted: Option<bool>

Whether planning exhausted the Delta scan metadata iterator.

scan_partitions_planned: u64

Final execution partitions planned for the scan, including source repartitioning.

files_planned: u64

Data files selected during planning.

files_filtered_during_planning: Option<u64>

Add actions filtered during planning, when known.

estimated_rows: Option<u64>

Estimated output rows, when every selected file reported row statistics.

estimated_bytes: Option<u64>

Estimated input bytes, when every selected file reported a size.

scan_partitions_started: u64

Scan partitions whose execution started.

scan_partitions_completed: u64

Scan partitions that completed normally.

files_started: u64

Data-file tasks that started, including independently read file ranges.

files_completed: u64

Data-file tasks that completed normally, including independently read file ranges.

batches_produced: u64

Backend-logical record batches handed to the scheduler.

rows_produced: u64

Backend-logical rows handed to the scheduler.

deletion_vector_payloads_loaded: u64

Deletion-vector payloads loaded.

deletion_vectors_applied: u64

Deletion-vector masks applied.

deletion_vector_rows_deleted: u64

Rows removed by deletion-vector masks.

deletion_vector_failures: u64

Deletion-vector read or masking failures.

deletion_vector_rejections: u64

Deletion-vector reads rejected by safety checks.

parquet_data_file_range_get_operations: Option<u64>

NativeAsync Parquet ranged GET operations, or None for another backend.

parquet_data_file_full_get_operations: Option<u64>

NativeAsync Parquet full GET operations, or None for another backend.

parquet_data_file_bytes_received: Option<u64>

NativeAsync Parquet payload bytes received, or None for another backend.

parquet_data_file_opened_bytes: Option<u64>

NativeAsync Parquet file bytes opened, or None for another backend.

Trait Implementations

impl Clone for DeltaReadMetricsSnapshot

fn clone(&self) -> DeltaReadMetricsSnapshot

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DeltaReadMetricsSnapshot

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

Formats the value using the given formatter.

impl Eq for DeltaReadMetricsSnapshot

impl PartialEq for DeltaReadMetricsSnapshot

fn eq(&self, other: &DeltaReadMetricsSnapshot) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for DeltaReadMetricsSnapshot