| 88 | : schema_(schema), batches_(batches), position_(0) {} |
| 89 | |
| 90 | std::shared_ptr<Schema> schema() const override { return schema_; } |
| 91 | |
| 92 | Status ReadNext(std::shared_ptr<RecordBatch>* out) override { |
| 93 | if (position_ >= batches_.size()) { |
no outgoing calls