Skip to content

Commit 32ba413

Browse files
Merge pull request apache#7 from irenjj/split
spilt into rewrite_dependent_join & decorrelate_dependent_join
2 parents a2abb7c + 47ace22 commit 32ba413

File tree

5 files changed

+1253
-1153
lines changed

5 files changed

+1253
-1153
lines changed

datafusion/expr/src/logical_plan/plan.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -364,7 +364,7 @@ impl Display for DependentJoin {
364364
let correlated_str = self
365365
.correlated_columns
366366
.iter()
367-
.map(|(level, col, data_type)| format!("{col} lvl {level}"))
367+
.map(|(level, col, _)| format!("{col} lvl {level}"))
368368
.collect::<Vec<String>>()
369369
.join(", ");
370370
let lateral_join_info =

0 commit comments

Comments
 (0)