Struct AggregateContext 

pub struct AggregateContext {
    pub input_rows: u64,
    pub group_keys: Vec<String>,
    pub agg_function_count: usize,
    pub memory_limit: u64,
    pub input_is_sorted: bool,
    pub sort_keys_match_group_keys: bool,
    pub is_deterministic: bool,
    pub complexity_score: u32,
    pub table_name: Option<String>,
}

Contextual information for the selection of aggregation strategies

Fields

input_rows: u64

Number of input lines

group_keys: Vec<String>

List of grouping keys

agg_function_count: usize

Number of aggregate functions

memory_limit: u64

Memory limit (in bytes; 0 indicates no limit)

input_is_sorted: bool

Are the input data already sorted?

sort_keys_match_group_keys: bool

Does the sorting key match the grouping key?

is_deterministic: bool

Are aggregate expressions deterministic?

complexity_score: u32

Aggregation expression complexity score

table_name: Option<String>

Table name (tag name) for statistics lookup

Implementations

impl AggregateContext

pub fn new( input_rows: u64, group_keys: Vec<String>, agg_function_count: usize, ) -> Self

Create a new aggregation context.

pub fn with_memory_limit(self, memory_limit: u64) -> Self

Setting memory limits

pub fn with_sorted_input(self, sort_keys_match: bool) -> Self

Set the input to be sorted.

pub fn with_expression_analysis( self, is_deterministic: bool, complexity_score: u32, ) -> Self

Setting expression properties

pub fn with_table_name(self, table_name: Option<String>) -> Self

Set table name for statistics lookup

Trait Implementations

impl Clone for AggregateContext

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 AggregateContext

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

Formats the value using the given formatter.