Struct DeltaScanMetricsSnapshot 

pub struct DeltaScanMetricsSnapshot {

    pub snapshot_version: u64,
    pub parquet_backend: ParquetReaderBackend,
    pub scan_partitions_planned: u64,
    pub files_planned: u64,
    pub add_actions_excluded_during_planning: Option<u64>,
    pub estimated_input_rows: Option<u64>,
    pub estimated_input_bytes: Option<u64>,
    pub scan_partitions_started: u64,
    pub scan_partitions_completed: u64,
    pub file_tasks_started: u64,
    pub file_tasks_completed: u64,
    pub scheduler_batches_emitted: u64,
    pub scheduler_rows_emitted: 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_coordinate_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 estimated_parquet_task_bytes_admitted: Option<u64>,
}

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

Fields

snapshot_version: u64

Delta snapshot version selected for the scan.

parquet_backend: ParquetReaderBackend

Parquet reader backend selected for the scan.

scan_partitions_planned: u64

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

files_planned: u64

Data files selected during planning.

add_actions_excluded_during_planning: Option<u64>

Add actions excluded during planning, when known.

estimated_input_rows: Option<u64>

Estimated rows in selected input files before row filtering, when known for every file.

estimated_input_bytes: Option<u64>

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

scan_partitions_started: u64

Scan partitions whose execution started.

scan_partitions_completed: u64

Scan partitions that completed normally.

file_tasks_started: u64

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

file_tasks_completed: u64

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

scheduler_batches_emitted: u64

Batches emitted by the scheduler before final stream operations.

scheduler_rows_emitted: u64

Rows emitted by the scheduler before final stream operations.

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_coordinate_rejections: u64

Deletion-vector coordinate operations rejected by safety checks.

parquet_data_file_range_get_operations: Option<u64>

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

parquet_data_file_full_get_operations: Option<u64>

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

parquet_data_file_bytes_received: Option<u64>

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

estimated_parquet_task_bytes_admitted: Option<u64>

Estimated bytes admitted across direct Parquet tasks, or None for another backend.

Trait Implementations

impl Clone for DeltaScanMetricsSnapshot

fn clone(&self) -> DeltaScanMetricsSnapshot

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DeltaScanMetricsSnapshot

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

Formats the value using the given formatter.

impl Eq for DeltaScanMetricsSnapshot

impl PartialEq for DeltaScanMetricsSnapshot

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for DeltaScanMetricsSnapshot