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