Method ResetKernelStates

cpp/src/arrow/acero/groupby_aggregate_node.cc:204–208

}

Status GroupByNode::ResetKernelStates() {
  auto ctx = plan()->query_context()->exec_context();
  ARROW_RETURN_NOT_OK(InitKernels(agg_kernels_, ctx, aggs_, agg_src_types_));
  return Status::OK();
}

Status GroupByNode::Consume(ExecSpan batch) {
  size_t thread_index = plan_->query_context()->GetThreadIndex();