Skip to content

Commit 1c21573

Browse files
committed
address comment
1 parent 977a0f2 commit 1c21573

File tree

2 files changed

+9
-0
lines changed

2 files changed

+9
-0
lines changed

datafusion/optimizer/src/decorrelate_lateral_join.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -78,6 +78,7 @@ fn rewrite_internal(join: Join) -> Result<Transformed<LogicalPlan>> {
7878
}
7979

8080
match join.right.apply_with_subqueries(|p| {
81+
// TODO: support outer joins
8182
if p.contains_outer_reference() {
8283
Ok(TreeNodeRecursion::Stop)
8384
} else {

datafusion/sqllogictest/test_files/join.slt.part

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1490,6 +1490,14 @@ SELECT * FROM t0, LATERAL (SELECT * FROM t1 WHERE t1.v0 = 1);
14901490
3 3 1 1
14911491
4 4 1 1
14921492

1493+
query IIII
1494+
SELECT * FROM t0 JOIN LATERAL (SELECT * FROM t1 WHERE t1.v0 = 1) on true;
1495+
----
1496+
1 1 1 1
1497+
1 2 1 1
1498+
3 3 1 1
1499+
4 4 1 1
1500+
14931501
statement ok
14941502
drop table t1;
14951503

0 commit comments

Comments
 (0)