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

Method Backpressure

cpp/src/arrow/dataset/scanner.cc:993–996  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

991}
992
993Status ScannerBuilder::Backpressure(acero::BackpressureOptions backpressure) {
994 scan_options_->backpressure = backpressure;
995 return Status::OK();
996}
997
998Result<std::shared_ptr<ScanOptions>> ScannerBuilder::GetScanOptions() {
999 if (!scan_options_->projection.IsBound()) {

Callers 1

MakeScannerMethod · 0.80

Calls 1

OKFunction · 0.50

Tested by 1

MakeScannerMethod · 0.64