[CALCITE-3729] Filters failed to be pushed down when it's identical to join condition.

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.22.0
• Labels: pull-request-available
• Assignee: Jin Xing
• Reporter: Jin Xing
• Created: 13/Jan/20 08:13
• Updated: 06/Mar/20 04:35
• Resolved: 13/Jan/20 10:36

Description

FilterJoinRule optimize below sql as

select * from sales.dept d inner join sales.emp e
on d.deptno = e.deptno and d.deptno > e.mgr
where d.deptno > e.mgr

LogicalProject(DEPTNO=[$0], NAME=[$1], EMPNO=[$2], ENAME=[$3], JOB=[$4], MGR=[$5], HIREDATE=[$6], SAL=[$7], COMM=[$8], DEPTNO0=[$9], SLACKER=[$10])
  LogicalFilter(condition=[>($0, $5)])
    LogicalJoin(condition=[AND(=($0, $9), >($0, $5))], joinType=[inner])
      LogicalTableScan(table=[[CATALOG, SALES, DEPT]])
      LogicalTableScan(table=[[CATALOG, SALES, EMP]])

 

The outer Filter failed to be pushed down into Join and removed.

Issue Links

• links to: GitHub Pull Request #1753