new_group_values

datafusion::physical_plan::aggregates::group_values

Function new_group_values 

Source 
pub fn new_group_values(
    schema: Arc<Schema>,
    group_ordering: &GroupOrdering,
) -> Result<Box<dyn GroupValues>, DataFusionError>
Expand description

Return a specialized implementation of GroupValues for the given schema.

GroupValues implementations choosing logic:

  • If group by single column, and type of this column has the specific GroupValues implementation, such implementation will be chosen.

  • If group by multiple columns, and all column types have the specific GroupColumn implementations, GroupValuesColumn will be chosen.

  • Otherwise, the general implementation GroupValuesRows will be chosen.

GroupColumn: crate::aggregates::group_values::multi_group_by::GroupColumn GroupValuesColumn: crate::aggregates::group_values::multi_group_by::GroupValuesColumn GroupValuesRows: crate::aggregates::group_values::row::GroupValuesRows