Skip to content
This repository has been archived by the owner on Jan 7, 2025. It is now read-only.

Commit

Permalink
Clippy
Browse files Browse the repository at this point in the history
  • Loading branch information
jurplel committed Dec 9, 2024
1 parent 9b9152c commit 3f03aca
Showing 1 changed file with 2 additions and 3 deletions.
5 changes: 2 additions & 3 deletions optd-datafusion-repr/src/rules/subquery/depjoin_pushdown.rs
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,6 @@
// Use of this source code is governed by an MIT-style license that can be found in the LICENSE file or at
// https://opensource.org/licenses/MIT.

use datafusion_expr::Aggregate;
use optd_core::nodes::{PlanNodeOrGroup, PredNode};
use optd_core::optimizer::Optimizer;
use optd_core::rules::{Rule, RuleMatcher};
Expand Down Expand Up @@ -98,7 +97,7 @@ fn apply_dep_initial_distinct(
)
.into_plan_node();
let right_count_star = LogicalAgg::new(
right_lim_1.into(),
right_lim_1,
ListPred::new(vec![FuncPred::new(
FuncType::Agg("count".to_string()),
ListPred::new(vec![ConstantPred::int64(1).into_pred_node()]),
Expand Down Expand Up @@ -178,7 +177,7 @@ fn apply_dep_initial_distinct(
//
// This is because the aggregate we install on the right side will map the
// correlated columns to their respective indices as shown.
assert!(correlated_col_indices.len() > 0);
assert!(!correlated_col_indices.is_empty());
let join_cond = match join.sq_type() {
SubqueryType::Scalar | SubqueryType::Exists => LogOpPred::new(
LogOpType::And,
Expand Down

0 comments on commit 3f03aca

Please sign in to comment.