Struct PhysicalAggregate 

pub struct PhysicalAggregate {
    pub input: Rc<PhysicalPlan>,
    pub group_exprs: Vec<Expr>,
    pub aggr_exprs: Vec<Expr>,
    pub schema: SchemaRef,
    pub output_rows: RefCell<Vec<Tuple>>,
    pub cursor: AtomicUsize,
}

Fields

input: Rc<PhysicalPlan>

The incoming physical plan

group_exprs: Vec<Expr>

Grouping expressions

aggr_exprs: Vec<Expr>

Aggregate expressions

schema: SchemaRef

The schema description of the aggregate output

output_rows: RefCell<Vec<Tuple>>

cursor: AtomicUsize

Implementations

impl PhysicalAggregate

pub fn new( input: Rc<PhysicalPlan>, group_exprs: Vec<Expr>, aggr_exprs: Vec<Expr>, schema: SchemaRef, ) -> Self

Trait Implementations

impl Debug for PhysicalAggregate

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

Formats the value using the given formatter.

impl Display for PhysicalAggregate

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

Formats the value using the given formatter.

impl VolcanoExecutor for PhysicalAggregate

fn init(&self, context: &mut ExecutionContext<'_>) -> QuillSQLResult<()>

fn next( &self, context: &mut ExecutionContext<'_>, ) -> QuillSQLResult<Option<Tuple>>

fn output_schema(&self) -> SchemaRef