| 2269 | |
| 2270 | protected: |
| 2271 | Status ReadNextArrayInternal(ArrayType* array) { |
| 2272 | ArrayTraits::MarkReleased(array); |
| 2273 | Status status = StatusFromCError(stream_.get_next(&stream_, array)); |
| 2274 | if (!status.ok()) { |
| 2275 | ArrayTraits::ReleaseFunc(array); |
| 2276 | } |
| 2277 | |
| 2278 | return status; |
| 2279 | } |
| 2280 | |
| 2281 | Result<std::shared_ptr<RecordBatch>> ImportRecordBatchInternal( |
| 2282 | struct ArrowArray* array, std::shared_ptr<Schema> schema) { |