| 2105 | } |
| 2106 | |
| 2107 | Result<RecordBatchVector> RecordBatchFileReader::ToRecordBatches() { |
| 2108 | RecordBatchVector batches; |
| 2109 | const auto n = num_record_batches(); |
| 2110 | for (int i = 0; i < n; ++i) { |
| 2111 | ARROW_ASSIGN_OR_RAISE(auto batch, ReadRecordBatch(i)); |
| 2112 | batches.emplace_back(std::move(batch)); |
| 2113 | } |
| 2114 | return batches; |
| 2115 | } |
| 2116 | |
| 2117 | Result<std::shared_ptr<Table>> RecordBatchFileReader::ToTable() { |
| 2118 | ARROW_ASSIGN_OR_RAISE(auto batches, ToRecordBatches()); |