Struct SourceReadRuntimeMetrics 

pub struct SourceReadRuntimeMetrics {

    pub query_id: Option<QueryId>,
    pub source_node_id: String,
    pub read_kind: String,
    pub read_strategy: String,
    pub parquet_read_evidence: SourceReadParquetEvidenceMetrics,
    pub batch_index: u64,
    pub chunk_count: u64,
    pub first_chunk_index: u64,
    pub last_chunk_index: u64,
    pub first_file_index: u64,
    pub last_file_index: u64,
    pub file_count: u64,
    pub row_group_count: u64,
    pub read_columns_per_file: u64,
    pub read_columns_total: u64,
    pub known_file_bytes: u64,
    pub estimated_source_read_bytes: u64,
    pub known_row_group_bytes: u64,
    pub known_projected_compressed_bytes: u64,
    pub known_projected_uncompressed_bytes: u64,
    pub known_pure_filter_compressed_bytes: u64,
    pub known_pure_filter_uncompressed_bytes: u64,
    pub output_rows: u64,
    pub reader_predicate: bool,
    pub reader_dynamic_filter_count: u64,
    pub source_batching_reason: String,
    pub source_chunk_planning_mode: String,
    pub source_chunk_planning_reason: String,
    pub elapsed: Duration,
}

Runtime evidence for one local-Parquet source read.

Fields

query_id: Option<QueryId>

Query-wide diagnostic correlation id, when assigned.

source_node_id: String

Native source node id.

read_kind: String

Source read shape, for example chunk or chunk_batch.

read_strategy: String

Parquet read strategy used by the chunk or batch.

parquet_read_evidence: SourceReadParquetEvidenceMetrics

Lower-layer Parquet read evidence reported by cudf.

batch_index: u64

Batch index within the source stream, or the chunk index for singleton reads.

chunk_count: u64

Number of source chunks represented by this read.

first_chunk_index: u64

First source chunk index represented by this read.

last_chunk_index: u64

Last source chunk index represented by this read.

first_file_index: u64

First source file index represented by this read.

last_file_index: u64

Last source file index represented by this read.

file_count: u64

Number of distinct files represented by this read.

row_group_count: u64

Selected row groups represented by this read.

read_columns_per_file: u64

Number of physical read columns per represented file.

read_columns_total: u64

Sum of physical read-column selections across represented files.

known_file_bytes: u64

Sum of known file bytes for represented files, when available.

estimated_source_read_bytes: u64

Best available source-read byte estimate for represented chunks.

known_row_group_bytes: u64

Sum of known selected row-group bytes, when available.

known_projected_compressed_bytes: u64

Sum of known projected compressed bytes, when available.

known_projected_uncompressed_bytes: u64

Sum of known projected uncompressed bytes, when available.

known_pure_filter_compressed_bytes: u64

Sum of known pure-filter compressed bytes, when available.

known_pure_filter_uncompressed_bytes: u64

Sum of known pure-filter uncompressed bytes, when available.

output_rows: u64

Number of output rows materialized by the read after reader predicates.

reader_predicate: bool

Whether this read carried a source reader predicate.

reader_dynamic_filter_count: u64

Number of dynamic-filter reader predicate routes attached to this read.

source_batching_reason: String

Stable diagnostic reason for the source chunk batching decision.

source_chunk_planning_mode: String

Source chunk planning mode requested for this source read.

source_chunk_planning_reason: String

Stable diagnostic reason for the source chunk row-group and byte target.

elapsed: Duration

Elapsed time spent in the source read.

Implementations

impl SourceReadRuntimeMetrics

pub fn to_json(&self) -> Value

Serializes this source-read runtime row as named JSON.

impl SourceReadRuntimeMetrics

pub fn to_stable_kv_row(&self) -> String

Serializes this row as stable comma-separated key/value pairs.

Trait Implementations

impl Clone for SourceReadRuntimeMetrics

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SourceReadRuntimeMetrics

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

Formats the value using the given formatter.

impl Default for SourceReadRuntimeMetrics

fn default() -> Self

Returns the “default value” for a type.

impl Eq for SourceReadRuntimeMetrics

impl PartialEq for SourceReadRuntimeMetrics

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for SourceReadRuntimeMetrics