Struct datafusion_expr::logical_plan::Aggregate
source · [−]pub struct Aggregate {
pub input: Arc<LogicalPlan>,
pub group_expr: Vec<Expr>,
pub aggr_expr: Vec<Expr>,
pub schema: DFSchemaRef,
}
Expand description
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>
Grouping expressions
aggr_expr: Vec<Expr>
Aggregate expressions
schema: DFSchemaRef
The schema description of the aggregate output
Implementations
sourceimpl Aggregate
impl Aggregate
pub fn try_new(
input: Arc<LogicalPlan>,
group_expr: Vec<Expr>,
aggr_expr: Vec<Expr>,
schema: DFSchemaRef
) -> Result<Self>
pub fn try_from_plan(plan: &LogicalPlan) -> Result<&Aggregate>
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for Aggregate
impl Send for Aggregate
impl Sync for Aggregate
impl Unpin for Aggregate
impl !UnwindSafe for Aggregate
Blanket Implementations
sourceimpl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more