Skip to content

Commit 502b7e3

Browse files
authored
reimplement eliminate_outer_join (#4272)
1 parent e817d75 commit 502b7e3

File tree

4 files changed

+137
-233
lines changed

4 files changed

+137
-233
lines changed

datafusion/expr/src/logical_plan/plan.rs

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -999,6 +999,12 @@ pub enum JoinType {
999999
RightAnti,
10001000
}
10011001

1002+
impl JoinType {
1003+
pub fn is_outer(self) -> bool {
1004+
self == JoinType::Left || self == JoinType::Right || self == JoinType::Full
1005+
}
1006+
}
1007+
10021008
impl Display for JoinType {
10031009
fn fmt(&self, f: &mut Formatter) -> fmt::Result {
10041010
let join_type = match self {

0 commit comments

Comments
 (0)