Struct GroupByMetrics 

pub(crate) struct GroupByMetrics {
    pub(crate) time_calculating_group_ids: Time,
    pub(crate) aggregate_arguments_time: Time,
    pub(crate) aggregation_time: Time,
    pub(crate) emitting_time: Time,
}

Fields

time_calculating_group_ids: Time

Time spent calculating the group IDs from the evaluated grouping columns.

aggregate_arguments_time: Time

Time spent evaluating the inputs to the aggregate functions.

aggregation_time: Time

Time spent evaluating the aggregate expressions themselves (e.g. summing all elements and counting number of elements for avg aggregate).

emitting_time: Time

Time spent emitting the final results and constructing the record batch which includes finalizing the grouping expressions (e.g. emit from the hash table in case of hash aggregation) and the accumulators

Implementations

impl GroupByMetrics

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