| 188 | const char* kind_name() const override { return "PivotLongerNode"; } |
| 189 | |
| 190 | Status InputFinished(ExecNode* input, int total_batches) override { |
| 191 | DCHECK_EQ(input, inputs_[0]); |
| 192 | EVENT_ON_CURRENT_SPAN("InputFinished", {{"batches.length", total_batches}}); |
| 193 | return output_->InputFinished( |
| 194 | this, total_batches * static_cast<int>(options_.row_templates.size())); |
| 195 | } |
| 196 | |
| 197 | Status StartProducing() override { |
| 198 | NoteStartProducing(ToStringExtra()); |