Skip to content

Commit 0145088

Browse files
committed
count group benchmark check
1 parent b3e064b commit 0145088

1 file changed

Lines changed: 2 additions & 22 deletions

File tree

datafusion/functions-aggregate/benches/count_distinct.rs

Lines changed: 2 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -224,11 +224,10 @@ fn count_distinct_groups_benchmark(c: &mut Criterion) {
224224
let (_schema, args) = prepare_args(DataType::Int64);
225225

226226
if count_fn.groups_accumulator_supported(args.clone()) {
227-
<<<<<<< Updated upstream
228227
c.bench_function(&format!("count_distinct_groups {name}"), |b| {
229228
b.iter(|| {
230-
let (_schema, args) = prepare_args(DataType::Int64);
231-
let mut acc = count_fn.create_groups_accumulator(args).unwrap();
229+
let mut acc =
230+
count_fn.create_groups_accumulator(args.clone()).unwrap();
232231
acc.update_batch(
233232
std::slice::from_ref(&values),
234233
&group_indices,
@@ -239,25 +238,6 @@ fn count_distinct_groups_benchmark(c: &mut Criterion) {
239238
acc.evaluate(EmitTo::All).unwrap()
240239
})
241240
});
242-
=======
243-
c.bench_function(
244-
&format!("count_distinct_groups i64 {num_groups} groups"),
245-
|b| {
246-
b.iter(|| {
247-
let mut acc =
248-
count_fn.create_groups_accumulator(args.clone()).unwrap();
249-
acc.update_batch(
250-
std::slice::from_ref(&values),
251-
&group_indices,
252-
None,
253-
num_groups,
254-
)
255-
.unwrap();
256-
acc.evaluate(EmitTo::All).unwrap()
257-
})
258-
},
259-
);
260-
>>>>>>> Stashed changes
261241
} else {
262242
c.bench_function(&format!("count_distinct_groups {name}"), |b| {
263243
b.iter(|| {

0 commit comments

Comments
 (0)