| 40 | TracedNode(this) {} |
| 41 | |
| 42 | Status MapNode::InputFinished(ExecNode* input, int total_batches) { |
| 43 | DCHECK_EQ(input, inputs_[0]); |
| 44 | EVENT_ON_CURRENT_SPAN("InputFinished", {{"batches.length", total_batches}}); |
| 45 | ARROW_RETURN_NOT_OK(output_->InputFinished(this, total_batches)); |
| 46 | if (input_counter_.SetTotal(total_batches)) { |
| 47 | this->Finish(); |
| 48 | } |
| 49 | return Status::OK(); |
| 50 | } |
| 51 | |
| 52 | // Right now this assumes the map operation will always maintain ordering. This |
| 53 | // may change in the future but is true for the current map nodes (filter/project) |
no test coverage detected