Struct SortMergeJoinMetrics 

pub(super) struct SortMergeJoinMetrics {
    join_time: Time,
    input_batches: Count,
    input_rows: Count,
    output_batches: Count,
    baseline_metrics: BaselineMetrics,
    peak_mem_used: Gauge,
    spill_metrics: SpillMetrics,
}

Metrics for SortMergeJoinExec

Fields

join_time: Time

Total time for joining probe-side batches to the build-side batches

input_batches: Count

Number of batches consumed by this operator

input_rows: Count

Number of rows consumed by this operator

output_batches: Count

Number of batches produced by this operator

baseline_metrics: BaselineMetrics

Execution metrics

peak_mem_used: Gauge

Peak memory used for buffered data. Calculated as sum of peak memory values across partitions

spill_metrics: SpillMetrics

Metrics related to spilling

Implementations

impl SortMergeJoinMetrics

pub fn new(partition: usize, metrics: &ExecutionPlanMetricsSet) -> Self

pub fn join_time(&self) -> Time

pub fn baseline_metrics(&self) -> BaselineMetrics

pub fn input_batches(&self) -> Count

pub fn input_rows(&self) -> Count

pub fn output_batches(&self) -> Count

pub fn peak_mem_used(&self) -> Gauge

pub fn spill_metrics(&self) -> SpillMetrics