| 88 | } |
| 89 | |
| 90 | static void FilterOverheadIsolated(benchmark::State& state, Expression expr) { |
| 91 | const int32_t batch_size = static_cast<int32_t>(state.range(0)); |
| 92 | const int32_t num_batches = kTotalBatchSize / batch_size; |
| 93 | arrow::acero::BatchesWithSchema data = MakeRandomBatches( |
| 94 | schema({field("i64", int64()), field("bool", boolean())}), num_batches, batch_size); |
| 95 | FilterNodeOptions options = FilterNodeOptions{expr}; |
| 96 | ASSERT_OK(BenchmarkIsolatedNodeOverhead(state, expr, num_batches, batch_size, data, |
| 97 | "filter", options)); |
| 98 | } |
| 99 | |
| 100 | arrow::compute::Expression complex_expression = |
| 101 | less(less(field_ref("i64"), literal(20)), greater(field_ref("i64"), literal(0))); |
nothing calls this directly
no test coverage detected