Method OutputNthBatch

cpp/src/arrow/acero/groupby_aggregate_node.cc:339–342

}

Status GroupByNode::OutputNthBatch(int64_t n) {
  int64_t batch_size = output_batch_size();
  return output_->InputReceived(this, out_data_.Slice(batch_size * n, batch_size));
}

Status GroupByNode::OutputResult(bool is_last) {
  // To simplify merging, ensure that the first grouper is nonempty