MCPcopy Create free account
hub / github.com/apache/arrow / ToRecordBatches

Method ToRecordBatches

cpp/src/arrow/ipc/reader.cc:2107–2115  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

2105}
2106
2107Result<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
2117Result<std::shared_ptr<Table>> RecordBatchFileReader::ToTable() {
2118 ARROW_ASSIGN_OR_RAISE(auto batches, ToRecordBatches());

Callers 6

TEST_FFunction · 0.45
DeclarationToBatchesImplFunction · 0.45
ReadBatchesMethod · 0.45
BatchesFromTableFunction · 0.45
ExecPlanReader__batchesFunction · 0.45

Calls 2

num_record_batchesFunction · 0.85
emplace_backMethod · 0.80

Tested by 2

TEST_FFunction · 0.36
ReadBatchesMethod · 0.36