| 100 | } |
| 101 | |
| 102 | std::shared_ptr<arrow::Schema> schema() const override { return schema_; } |
| 103 | |
| 104 | arrow::Status ReadNext(std::shared_ptr<arrow::RecordBatch>* batch_out) override { |
| 105 | // If this is the first batch getting pulled, tell the exec plan to |
no outgoing calls
no test coverage detected