Struct datafusion::physical_plan::hash_aggregate::HashAggregateExec [−][src]
pub struct HashAggregateExec { /* fields omitted */ }
Hash aggregate execution plan
Implementations
impl HashAggregateExec
[src]
impl HashAggregateExec
[src]pub fn try_new(
mode: AggregateMode,
group_expr: Vec<(Arc<dyn PhysicalExpr>, String)>,
aggr_expr: Vec<Arc<dyn AggregateExpr>>,
input: Arc<dyn ExecutionPlan>,
input_schema: SchemaRef
) -> Result<Self>
[src]
mode: AggregateMode,
group_expr: Vec<(Arc<dyn PhysicalExpr>, String)>,
aggr_expr: Vec<Arc<dyn AggregateExpr>>,
input: Arc<dyn ExecutionPlan>,
input_schema: SchemaRef
) -> Result<Self>
Create a new hash aggregate execution plan
pub fn mode(&self) -> &AggregateMode
[src]
Aggregation mode (full, partial)
pub fn group_expr(&self) -> &[(Arc<dyn PhysicalExpr>, String)]
[src]
Grouping expressions
pub fn aggr_expr(&self) -> &[Arc<dyn AggregateExpr>]
[src]
Aggregate expressions
pub fn input(&self) -> &Arc<dyn ExecutionPlan>
[src]
Input plan
pub fn input_schema(&self) -> SchemaRef
[src]
Get the input schema before any aggregates are applied
Trait Implementations
impl ExecutionPlan for HashAggregateExec
[src]
impl ExecutionPlan for HashAggregateExec
[src]fn as_any(&self) -> &dyn Any
[src]
Return a reference to Any that can be used for downcasting
fn schema(&self) -> SchemaRef
[src]
fn children(&self) -> Vec<Arc<dyn ExecutionPlan>>
[src]
fn required_child_distribution(&self) -> Distribution
[src]
fn output_partitioning(&self) -> Partitioning
[src]
Get the output partitioning of this plan
fn execute<'life0, 'async_trait>(
&'life0 self,
partition: usize
) -> Pin<Box<dyn Future<Output = Result<SendableRecordBatchStream>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
[src]
&'life0 self,
partition: usize
) -> Pin<Box<dyn Future<Output = Result<SendableRecordBatchStream>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn with_new_children(
&self,
children: Vec<Arc<dyn ExecutionPlan>>
) -> Result<Arc<dyn ExecutionPlan>>
[src]
&self,
children: Vec<Arc<dyn ExecutionPlan>>
) -> Result<Arc<dyn ExecutionPlan>>
fn metrics(&self) -> HashMap<String, SQLMetric>
[src]
Auto Trait Implementations
impl !RefUnwindSafe for HashAggregateExec
impl !RefUnwindSafe for HashAggregateExec
impl Send for HashAggregateExec
impl Send for HashAggregateExec
impl Sync for HashAggregateExec
impl Sync for HashAggregateExec
impl Unpin for HashAggregateExec
impl Unpin for HashAggregateExec
impl !UnwindSafe for HashAggregateExec
impl !UnwindSafe for HashAggregateExec