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

Method HasBatchDelivered

cpp/src/arrow/dataset/scanner_test.cc:309–311  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

307 return fragment_scanner_->HasStarted(batch_index);
308 }
309 bool HasBatchDelivered(int batch_index) {
310 return fragment_scanner_->HasDelivered(batch_index);
311 }
312
313 std::shared_ptr<MockFragmentScanner> fragment_scanner_;
314 Future<std::shared_ptr<FragmentScanner>> fragment_scanner_future_ =

Callers 1

CheckScannerBackpressureFunction · 0.80

Calls 1

HasDeliveredMethod · 0.80

Tested by

no test coverage detected