MCPcopy Create free account
hub / github.com/apache/arrow / InputFinished

Method InputFinished

cpp/src/arrow/acero/pivot_longer_node.cc:190–195  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

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());

Callers

nothing calls this directly

Calls 1

sizeMethod · 0.45

Tested by

no test coverage detected