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

Method ReadNext

cpp/src/arrow/dataset/scanner.cc:104–112  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

102
103 std::shared_ptr<Schema> schema() const override { return schema_; }
104 Status ReadNext(std::shared_ptr<RecordBatch>* batch) override {
105 ARROW_ASSIGN_OR_RAISE(auto next, delegate_.Next());
106 if (IsIterationEnd(next)) {
107 *batch = nullptr;
108 } else {
109 *batch = std::move(next.record_batch);
110 }
111 return Status::OK();
112 }
113
114 Status Close() override {
115 std::shared_ptr<RecordBatch> batch;

Callers 2

NextMethod · 0.45
TEST_FFunction · 0.45

Calls 2

IsIterationEndFunction · 0.85
OKFunction · 0.50

Tested by 1

TEST_FFunction · 0.36