| 112 | } |
| 113 | |
| 114 | Status Close() override { |
| 115 | std::shared_ptr<RecordBatch> batch; |
| 116 | RETURN_NOT_OK(ReadNext(&batch)); |
| 117 | while (batch != nullptr) { |
| 118 | RETURN_NOT_OK(ReadNext(&batch)); |
| 119 | } |
| 120 | return Status::OK(); |
| 121 | } |
| 122 | |
| 123 | private: |
| 124 | std::shared_ptr<Schema> schema_; |