Method InputReceived

cpp/src/arrow/acero/map_node.cc:71–84

Status MapNode::StopProducingImpl() { return Status::OK(); }

Status MapNode::InputReceived(ExecNode* input, ExecBatch batch) {
  auto scope = TraceInputReceived(batch);
  DCHECK_EQ(input, inputs_[0]);
  compute::Expression guarantee = batch.guarantee;
  int64_t index = batch.index;
  ARROW_ASSIGN_OR_RAISE(auto output_batch, ProcessBatch(std::move(batch)));
  output_batch.guarantee = guarantee;
  output_batch.index = index;
  ARROW_RETURN_NOT_OK(output_->InputReceived(this, std::move(output_batch)));
  if (input_counter_.Increment()) {
    this->Finish();
  }
  return Status::OK();
}

void MapNode::Finish() {}