File tree Expand file tree Collapse file tree
datafusion/functions-aggregate/benches Expand file tree Collapse file tree Original file line number Diff line number Diff 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 ( || {
You can’t perform that action at this time.
0 commit comments