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

Method ToRecordBatches

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

Source from the content-addressed store, hash-verified

2116}
2117
2118Result<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
2128Result<std::shared_ptr<Table>> RecordBatchFileReader::ToTable() {
2129 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