Skip to main content

execute

Function execute 

Source
pub async fn execute(
    ctx: &SessionContext,
    current_table: &str,
    spec: &AggregateSpec,
) -> Result<String, ChartError>
Expand description

Execute the aggregate stage.

Generates SQL from the aggregate spec, executes via DataFusion, and registers the result as a new table.

Returns the name of the output table.