Skip to main content

merge_op_for_aggregate_expr

flow::batching_mode::utils

Function merge_op_for_aggregate_expr 

Source 
fn merge_op_for_aggregate_expr(
    aggr_expr: &Expr,
    input_schema: &DFSchema,
) -> Result<IncrementalAggregateMergeOp, String>