Struct LoweredAggregateBuilder 

pub struct LoweredAggregateBuilder<'a> { /* private fields */ }

Builder for converting a logical aggregate Expr into physical aggregate planning pieces.

This builder handles the logical-to-physical work needed for aggregate planning: unwrapping aggregate aliases, choosing the output name, preserving user-facing display text, lowering aggregate arguments, lowering the optional filter, and lowering aggregate ORDER BY expressions.

Implementations

impl<'a> LoweredAggregateBuilder<'a>

pub fn new( expr: &'a Expr, logical_input_schema: &'a DFSchema, physical_input_schema: &'a Schema, execution_props: &'a ExecutionProps, ) -> Self

Create a builder for lowering expr.

logical_input_schema is used to resolve logical expressions such as columns, while physical_input_schema is the input schema used by the physical aggregate expression.

pub fn with_name(self, name: impl Into<String>) -> Self

Override the output column name for the aggregate.

If this is not set, the builder uses the alias from expr when present, or derives the physical name from the aggregate expression.

pub fn with_human_display(self, human_display: impl Into<String>) -> Self

Override the human-readable display text for the aggregate.

This is useful when a caller has already computed the exact display text it wants to preserve. When this override is used, aliases with metadata are still unwrapped for planning, but alias metadata is not copied to the aggregate output field.

pub fn build(self) -> Result<LoweredAggregate>

Lower the logical aggregate expression into physical aggregate pieces.