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