| 38 | namespace acero { |
| 39 | |
| 40 | Result<std::shared_ptr<Table>> TableGroupBy( |
| 41 | std::shared_ptr<Table> table, std::vector<Aggregate> aggregates, |
| 42 | std::vector<FieldRef> keys, bool use_threads = false, |
| 43 | MemoryPool* memory_pool = default_memory_pool()) { |
| 44 | Declaration plan = Declaration::Sequence( |
| 45 | {{"table_source", TableSourceNodeOptions(std::move(table))}, |
| 46 | {"aggregate", AggregateNodeOptions(std::move(aggregates), std::move(keys))}}); |
| 47 | return DeclarationToTable(std::move(plan), use_threads, memory_pool); |
| 48 | } |
| 49 | |
| 50 | TEST(GroupByConvenienceFunc, Basic) { |
| 51 | std::shared_ptr<Schema> in_schema = |
no test coverage detected