| 113 | virtual const std::shared_ptr<Field> field() = 0; |
| 114 | |
| 115 | ::arrow::Status NextBatch(int64_t batch_size, |
| 116 | std::shared_ptr<::arrow::ChunkedArray>* out) final { |
| 117 | RETURN_NOT_OK(LoadBatch(batch_size)); |
| 118 | RETURN_NOT_OK(BuildArray(batch_size, out)); |
| 119 | for (int x = 0; x < (*out)->num_chunks(); x++) { |
| 120 | RETURN_NOT_OK((*out)->chunk(x)->Validate()); |
| 121 | } |
| 122 | return Status::OK(); |
| 123 | } |
| 124 | |
| 125 | virtual ::arrow::Status LoadBatch(int64_t num_records) = 0; |
| 126 |