| 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; |
nothing calls this directly
no test coverage detected