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

Method MakeScanner

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

Source from the content-addressed store, hash-verified

1975 }
1976
1977 std::shared_ptr<Scanner> MakeScanner(::arrow::internal::Executor* io_executor) {
1978 acero::BackpressureOptions low_backpressure(kResumeIfBelowBytes, kPauseIfAboveBytes);
1979 io::IOContext io_context(default_memory_pool(), io_executor);
1980 std::shared_ptr<Dataset> dataset = MakeDataset();
1981 std::shared_ptr<ScanOptions> options = std::make_shared<ScanOptions>();
1982 options->io_context = io_context;
1983 ScannerBuilder builder(std::move(dataset), options);
1984 ARROW_EXPECT_OK(builder.UseThreads(false));
1985 ARROW_EXPECT_OK(builder.Backpressure(low_backpressure));
1986 EXPECT_OK_AND_ASSIGN(auto scanner, builder.Finish());
1987 return scanner;
1988 }
1989
1990 int TotalBatchesRead() {
1991 int sum = 0;

Callers

nothing calls this directly

Calls 3

default_memory_poolFunction · 0.85
BackpressureMethod · 0.80
UseThreadsMethod · 0.45

Tested by

no test coverage detected