| 138 | : done_(false), schema_(reader->schema()), reader_(reader), num_rows_(num_rows) {} |
| 139 | |
| 140 | std::shared_ptr<arrow::Schema> schema() const override { return schema_; } |
| 141 | |
| 142 | arrow::Status ReadNext(std::shared_ptr<arrow::RecordBatch>* batch_out) override { |
| 143 | if (done_) { |
no outgoing calls
no test coverage detected