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

Method ReadRecordBatchAsync

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

Source from the content-addressed store, hash-verified

1392 }
1393
1394 Future<std::shared_ptr<RecordBatch>> ReadRecordBatchAsync(int i) {
1395 DCHECK_GE(i, 0);
1396 DCHECK_LT(i, num_record_batches());
1397
1398 auto cached_metadata = cached_metadata_.find(i);
1399 if (cached_metadata != cached_metadata_.end()) {
1400 return ReadCachedRecordBatch(i, cached_metadata->second);
1401 }
1402
1403 return Status::Invalid(
1404 "Asynchronous record batch reading is only supported after a call to "
1405 "PreBufferMetadata or PreBufferBatches");
1406 }
1407
1408 Result<std::shared_ptr<RecordBatch>> ReadRecordBatch(int i) override {
1409 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