Struct DeltaProviderReadStatsSnapshot 

pub struct DeltaProviderReadStatsSnapshot {

    pub source_name: String,
    pub snapshot_version: u64,
    pub reader_backend: DeltaProviderReaderBackend,
    pub scan_metadata_exhausted: Option<bool>,
    pub scan_partitions_planned: u64,
    pub files_planned: u64,
    pub estimated_rows: Option<u64>,
    pub estimated_bytes: Option<u64>,
    pub datafusion_output_batch_size: Option<u64>,
    pub scan_partitions_started: u64,
    pub scan_partitions_completed: u64,
    pub files_started: u64,
    pub files_completed: u64,
    pub dynamic_partition_files_pruned: u64,
    pub dynamic_partition_files_kept: u64,
    pub dynamic_filters_received: u64,
    pub dynamic_filters_accepted: u64,
    pub dynamic_filters_unsupported: u64,
    pub dynamic_filter_snapshots: u64,
    pub dynamic_partition_files_not_pruned_missing_metadata: u64,
    pub dynamic_partition_files_not_pruned_unsupported_expression: 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,
}

Immutable view of provider read progress for one physical scan.

Fields

source_name: String

DataFusion table name for this source.

snapshot_version: u64

Delta snapshot version selected for this scan.

reader_backend: DeltaProviderReaderBackend

Provider file-reader backend selected for this scan.

scan_metadata_exhausted: Option<bool>

Whether metadata expansion exhausted the upstream kernel scan iterator.

scan_partitions_planned: u64

Planned DataFusion execution partitions for this scan.

files_planned: u64

Selected provider file tasks planned for this scan.

estimated_rows: Option<u64>

Estimated output rows from planning when every selected file had stats.

estimated_bytes: Option<u64>

Estimated bytes from planning when every selected file had a byte size.

datafusion_output_batch_size: Option<u64>

Effective DataFusion task batch size observed when execution starts.

This records the upstream query-engine setting. It does not claim every produced or final query-output batch has exactly this many rows.

scan_partitions_started: u64

Execution partitions whose stream was started by DataFusion.

scan_partitions_completed: u64

Execution partitions whose stream reached normal completion.

files_started: u64

File-read handoffs that were started.

files_completed: u64

File-read handoffs that finished successfully.

dynamic_partition_files_pruned: u64

File tasks skipped before read scheduling by dynamic partition pruning.

dynamic_partition_files_kept: u64

File tasks kept after dynamic partition pruning evaluation.

dynamic_filters_received: u64

Post-phase physical filters offered to the Delta dynamic filter hook.

dynamic_filters_accepted: u64

Offered dynamic filters retained for partition pruning.

dynamic_filters_unsupported: u64

Offered filters rejected by the dynamic filter hook policy.

dynamic_filter_snapshots: u64

Attempts to snapshot a retained dynamic filter during file admission.

dynamic_partition_files_not_pruned_missing_metadata: u64

Kept file tasks with missing, invalid, or unparsable partition metadata.

dynamic_partition_files_not_pruned_unsupported_expression: u64

Kept file tasks with unsupported or failed dynamic partition evaluation.

batches_produced: u64

Record batches sent toward DataFusion.

rows_produced: u64

Rows sent toward DataFusion after transform and DV filtering.

deletion_vector_payloads_loaded: u64

Deletion-vector payloads loaded for selected files.

deletion_vectors_applied: u64

Deletion-vector masks applied to selected files.

deletion_vector_rows_deleted: u64

Rows removed by deletion-vector masks when known.

deletion_vector_failures: u64

Deletion-vector read or masking failures.

deletion_vector_rejections: u64

Deletion-vector reads rejected by safety gates.

Trait Implementations

impl Clone for DeltaProviderReadStatsSnapshot

fn clone(&self) -> DeltaProviderReadStatsSnapshot

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DeltaProviderReadStatsSnapshot

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

Formats the value using the given formatter.

impl Eq for DeltaProviderReadStatsSnapshot

impl PartialEq for DeltaProviderReadStatsSnapshot

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for DeltaProviderReadStatsSnapshot