| 2048 | } |
| 2049 | |
| 2050 | Status ExportStreamNext(const std::shared_ptr<RecordBatchReader>& src, int64_t i, |
| 2051 | struct ArrowArray* out_array) { |
| 2052 | std::shared_ptr<RecordBatch> batch; |
| 2053 | RETURN_NOT_OK(src->ReadNext(&batch)); |
| 2054 | if (batch == nullptr) { |
| 2055 | // End of stream |
| 2056 | ArrowArrayMarkReleased(out_array); |
| 2057 | return Status::OK(); |
| 2058 | } else { |
| 2059 | return ExportRecordBatch(*batch, out_array); |
| 2060 | } |
| 2061 | } |
| 2062 | |
| 2063 | // the int64_t i input here is unused, but exists simply to allow utilizing the |
| 2064 | // overload of this with the version for ChunkedArrays. If we removed the int64_t |
no test coverage detected