| 2116 | } |
| 2117 | |
| 2118 | Result<RecordBatchVector> RecordBatchFileReader::ToRecordBatches() { |
| 2119 | RecordBatchVector batches; |
| 2120 | const auto n = num_record_batches(); |
| 2121 | for (int i = 0; i < n; ++i) { |
| 2122 | ARROW_ASSIGN_OR_RAISE(auto batch, ReadRecordBatch(i)); |
| 2123 | batches.emplace_back(std::move(batch)); |
| 2124 | } |
| 2125 | return batches; |
| 2126 | } |
| 2127 | |
| 2128 | Result<std::shared_ptr<Table>> RecordBatchFileReader::ToTable() { |
| 2129 | ARROW_ASSIGN_OR_RAISE(auto batches, ToRecordBatches()); |