| 252 | } |
| 253 | |
| 254 | static void ScanBenchmark_Customize(benchmark::internal::Benchmark* b) { |
| 255 | for (const int32_t num_batches : {1000}) { |
| 256 | for (const int batch_size : {10, 100, 1000}) { |
| 257 | for (const int scan_idx : {kScanIdx, kScanV2Idx}) { |
| 258 | b->Args({num_batches, batch_size, scan_idx}); |
| 259 | RecordBatchVector batches = |
| 260 | ::arrow::compute::GenerateBatches(GetSchema(), num_batches, batch_size); |
| 261 | StoreBatches(num_batches, batch_size, batches); |
| 262 | } |
| 263 | } |
| 264 | } |
| 265 | b->ArgNames({"num_batches", "batch_size", "scan_alg"}); |
| 266 | b->UseRealTime(); |
| 267 | } |
| 268 | |
| 269 | BENCHMARK(MinimalEndToEndBench)->Apply(ScanBenchmark_Customize); |
| 270 | BENCHMARK(ScanOnlyBench)->Apply(ScanBenchmark_Customize); |
nothing calls this directly
no test coverage detected