Struct datafusion::logical_plan::plan::Aggregate

pub struct Aggregate {
    pub input: Arc<LogicalPlan>,
    pub group_expr: Vec<Expr, Global>,
    pub aggr_expr: Vec<Expr, Global>,
    pub schema: Arc<DFSchema>,
}

Aggregates its input based on a set of grouping and aggregate expressions (e.g. SUM).

Fields

input: Arc<LogicalPlan>

The incoming logical plan

group_expr: Vec<Expr, Global>

Grouping expressions

aggr_expr: Vec<Expr, Global>

Aggregate expressions

schema: Arc<DFSchema>

The schema description of the aggregate output

Implementations

impl Aggregate

pub fn try_new(
    input: Arc<LogicalPlan>,
    group_expr: Vec<Expr, Global>,
    aggr_expr: Vec<Expr, Global>,
    schema: Arc<DFSchema>
) -> Result<Aggregate, DataFusionError>

pub fn try_from_plan(plan: &LogicalPlan) -> Result<&Aggregate, DataFusionError>

Trait Implementations

impl Clone for Aggregate

fn clone(&self) -> Aggregate

Returns a copy of the value.

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

Performs copy-assignment from source.