| 448 | [[nodiscard]] std::shared_ptr<Schema> schema() const override { return schema_; } |
| 449 | |
| 450 | Status ReadNext(std::shared_ptr<RecordBatch>* out) override { |
| 451 | auto result = ReadNextAsync().result(); |
| 452 | return std::move(result).Value(out); |
| 453 | } |
| 454 | |
| 455 | Future<std::shared_ptr<RecordBatch>> ReadNextAsync() override { |
| 456 | // On the first call, return the batch we used for initialization |