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