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