Skip to content

Commit f302d46

Browse files
committed
fmt
1 parent f6e8d68 commit f302d46

2 files changed

Lines changed: 9 additions & 13 deletions

File tree

datafusion/core/benches/sql_planner_extended.rs

Lines changed: 8 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -513,17 +513,14 @@ fn criterion_benchmark(c: &mut Criterion) {
513513
control_group.finish();
514514

515515
let chained_df = build_chained_case_projection_df(&rt, 80, 23, 30);
516-
c.bench_function(
517-
"physical_plan_chained_case_projection_hotspot",
518-
|b| {
519-
b.iter(|| {
520-
let df_clone = chained_df.clone();
521-
black_box(rt.block_on(async {
522-
df_clone.create_physical_plan().await.unwrap()
523-
}));
524-
})
525-
},
526-
);
516+
c.bench_function("physical_plan_chained_case_projection_hotspot", |b| {
517+
b.iter(|| {
518+
let df_clone = chained_df.clone();
519+
black_box(
520+
rt.block_on(async { df_clone.create_physical_plan().await.unwrap() }),
521+
);
522+
})
523+
});
527524

528525
let mut chained_group =
529526
c.benchmark_group("physical_plan_chained_case_projection_sweep");

datafusion/physical-plan/src/projection.rs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1022,8 +1022,7 @@ fn try_collapse_projection_chain(
10221022
let mut collapsed_any = false;
10231023

10241024
'outer: loop {
1025-
let Some(inner_proj) = current_input.downcast_ref::<ProjectionExec>()
1026-
else {
1025+
let Some(inner_proj) = current_input.downcast_ref::<ProjectionExec>() else {
10271026
break;
10281027
};
10291028

0 commit comments

Comments
 (0)