Struct DeltaDataFusionMetricsSnapshot 

pub struct DeltaDataFusionMetricsSnapshot {
    pub reader: DeltaReadMetricsSnapshot,
    pub output_batch_size: Option<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_files_not_pruned_missing_metadata: u64,
    pub dynamic_files_not_pruned_unsupported_expression: u64,
}

Immutable point-in-time DataFusion scan metrics.

Fields

reader: DeltaReadMetricsSnapshot

Core reader planning and execution metrics.

output_batch_size: Option<u64>

Effective DataFusion task batch size observed at execution.

dynamic_partition_files_pruned: u64

Files pruned before admission by a dynamic partition filter.

dynamic_partition_files_kept: u64

Files kept after consulting retained dynamic partition filters.

dynamic_filters_received: u64

Physical filters offered to the post-optimization hook.

dynamic_filters_accepted: u64

Offered filters retained for dynamic partition pruning.

dynamic_filters_unsupported: u64

Offered filters rejected by the dynamic partition policy.

dynamic_filter_snapshots: u64

Current dynamic expressions consulted during file admission.

dynamic_files_not_pruned_missing_metadata: u64

Kept files with missing, invalid, or unparsable partition metadata.

dynamic_files_not_pruned_unsupported_expression: u64

Kept files with unavailable, unsupported, or failed expressions.

Trait Implementations

impl Clone for DeltaDataFusionMetricsSnapshot

fn clone(&self) -> DeltaDataFusionMetricsSnapshot

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DeltaDataFusionMetricsSnapshot

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

Formats the value using the given formatter.

impl Eq for DeltaDataFusionMetricsSnapshot

impl PartialEq for DeltaDataFusionMetricsSnapshot

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for DeltaDataFusionMetricsSnapshot