Skip to content

Commit 0c4ee79

Browse files
committed
fix
1 parent 8c86f65 commit 0c4ee79

6 files changed

Lines changed: 6 additions & 6 deletions

File tree

datafusion/physical-optimizer/src/combine_partial_final_agg.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ impl PhysicalOptimizerRule for CombinePartialFinalAggregate {
4949
fn optimize_plan(
5050
&self,
5151
plan: Arc<dyn ExecutionPlan>,
52-
context: &OptimizerContext,
52+
_context: &OptimizerContext,
5353
) -> Result<Arc<dyn ExecutionPlan>> {
5454
plan.transform_down(|plan| {
5555
// Check if the plan is AggregateExec

datafusion/physical-optimizer/src/ensure_coop.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -64,7 +64,7 @@ impl PhysicalOptimizerRule for EnsureCooperative {
6464
fn optimize_plan(
6565
&self,
6666
plan: Arc<dyn ExecutionPlan>,
67-
context: &OptimizerContext,
67+
_context: &OptimizerContext,
6868
) -> Result<Arc<dyn ExecutionPlan>> {
6969
plan.transform_up(|plan| {
7070
let is_leaf = plan.children().is_empty();

datafusion/physical-optimizer/src/limit_pushdown.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ impl PhysicalOptimizerRule for LimitPushdown {
6262
fn optimize_plan(
6363
&self,
6464
plan: Arc<dyn ExecutionPlan>,
65-
context: &OptimizerContext,
65+
_context: &OptimizerContext,
6666
) -> Result<Arc<dyn ExecutionPlan>> {
6767
let global_state = GlobalRequirements {
6868
fetch: None,

datafusion/physical-optimizer/src/output_requirements.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -305,7 +305,7 @@ impl PhysicalOptimizerRule for OutputRequirements {
305305
fn optimize_plan(
306306
&self,
307307
plan: Arc<dyn ExecutionPlan>,
308-
context: &OptimizerContext,
308+
_context: &OptimizerContext,
309309
) -> Result<Arc<dyn ExecutionPlan>> {
310310
match self.mode {
311311
RuleMode::Add => require_top_ordering(plan),

datafusion/physical-optimizer/src/projection_pushdown.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -59,7 +59,7 @@ impl PhysicalOptimizerRule for ProjectionPushdown {
5959
fn optimize_plan(
6060
&self,
6161
plan: Arc<dyn ExecutionPlan>,
62-
context: &OptimizerContext,
62+
_context: &OptimizerContext,
6363
) -> Result<Arc<dyn ExecutionPlan>> {
6464
let alias_generator = AliasGenerator::new();
6565
let plan = plan

datafusion/physical-optimizer/src/update_aggr_exprs.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -72,7 +72,7 @@ impl PhysicalOptimizerRule for OptimizeAggregateOrder {
7272
fn optimize_plan(
7373
&self,
7474
plan: Arc<dyn ExecutionPlan>,
75-
context: &OptimizerContext,
75+
_context: &OptimizerContext,
7676
) -> Result<Arc<dyn ExecutionPlan>> {
7777
plan.transform_up(|plan| {
7878
if let Some(aggr_exec) = plan.as_any().downcast_ref::<AggregateExec>() {

0 commit comments

Comments
 (0)