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

Method ReadRecordBatchAsync

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

Source from the content-addressed store, hash-verified

1397 }
1398
1399 Future<std::shared_ptr<RecordBatch>> ReadRecordBatchAsync(int i) {
1400 DCHECK_GE(i, 0);
1401 DCHECK_LT(i, num_record_batches());
1402
1403 auto cached_metadata = cached_metadata_.find(i);
1404 if (cached_metadata != cached_metadata_.end()) {
1405 return ReadCachedRecordBatch(i, cached_metadata->second);
1406 }
1407
1408 return Status::Invalid(
1409 "Asynchronous record batch reading is only supported after a call to "
1410 "PreBufferMetadata or PreBufferBatches");
1411 }
1412
1413 Result<std::shared_ptr<RecordBatch>> ReadRecordBatch(int i) override {
1414 ARROW_ASSIGN_OR_RAISE(auto batch_with_metadata, ReadRecordBatchWithCustomMetadata(i));

Callers 1

operator()Method · 0.80

Calls 4

num_record_batchesFunction · 0.85
InvalidFunction · 0.50
findMethod · 0.45
endMethod · 0.45

Tested by

no test coverage detected