[ARROW-11840] [C++][Compute] Support merging GroupByState for multithreaded aggregation

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 3.0.0
• Component/s: C++
• Labels: compute
• External issue URL: https://github.com/apache/arrow/issues/27687
• Assignee: Unassigned
• Reporter: Ben Kietzman
• Created: 02/Mar/21 16:50
• Updated: 11/Jan/23 08:22
• Resolved: 26/Jul/21 14:38

Description

ARROW-11591 adds support for grouped aggregation, but defers merging (which is non-trivial and unnecessary for single threaded aggregation). Eventually it will be required to support merging, however: when aggregating in a multithreaded dataset scan, each thread's results will need to be combined after the scan is completed.

Note that currently ScalarAggExecutor::Consume assumes that merging aggregations is not costly (true for small aggregation state as with "mean", but false for "group_by"), and invokes ScalarAggregateKernel::merge for each input batch. ARROW-11591 introduces "group_by" as a special case which will not be merged for each input batch but Ideally this assumption would not be made for any kernel. When removing it, be sure that merging other aggregates continues to be tested.

Issue Links

• is fixed by: ARROW-12759 [C++][Compute] Wrap grouped aggregation in an ExecNode