Package org.apache.calcite.rel.rules

Class MinusToAntiJoinRule

java.lang.Object
org.apache.calcite.plan.RelOptRule
org.apache.calcite.plan.RelRule<MinusToAntiJoinRule.Config>
org.apache.calcite.rel.rules.MinusToAntiJoinRule
All Implemented Interfaces:
TransformationRule
@Enclosing public class MinusToAntiJoinRule extends RelRule<MinusToAntiJoinRule.Config> implements TransformationRule
Planner rule that translates a Minus to a series of Join that type is JoinRelType.ANTI. This rule supports n-way Minus conversion, as this rule can be repeatedly applied during query optimization to refine the plan.

Example for 2-way

Original sql: 


 select ename from emp where deptno = 10
 except
 select ename from emp where deptno = 20

Original plan: 


 LogicalMinus(all=[false])
   LogicalProject(ENAME=[$1])
     LogicalFilter(condition=[=($7, 10)])
       LogicalTableScan(table=[[CATALOG, SALES, EMP]])
   LogicalProject(ENAME=[$1])
     LogicalFilter(condition=[=($7, 20)])

Plan after conversion: 


 LogicalAggregate(group=[{0}])
   LogicalJoin(condition=[IS NOT DISTINCT FROM($0, $1)], joinType=[anti])
     LogicalProject(ENAME=[$1])
       LogicalFilter(condition=[=($7, 10)])
         LogicalTableScan(table=[[CATALOG, SALES, EMP]])
     LogicalProject(ENAME=[$1])
       LogicalFilter(condition=[=($7, 20)])
         LogicalTableScan(table=[[CATALOG, SALES, EMP]])

Example for n-way

Original sql: 


 select ename from emp where deptno = 10
 except
 select deptno from emp where ename in ('a', 'b')
 except
 select ename from empnullables

Original plan: 


 LogicalMinus(all=[false])
   LogicalProject(ENAME=[$1])
     LogicalFilter(condition=[=($7, 10)])
       LogicalTableScan(table=[[CATALOG, SALES, EMP]])
   LogicalProject(DEPTNO=[CAST($7):VARCHAR NOT NULL])
     LogicalFilter(condition=[OR(=($1, 'a'), =($1, 'b'))])
       LogicalTableScan(table=[[CATALOG, SALES, EMP]])
   LogicalProject(ENAME=[$1])
     LogicalTableScan(table=[[CATALOG, SALES, EMPNULLABLES]])

Plan after conversion: 


 LogicalProject(ENAME=[CAST($0):VARCHAR])
   LogicalAggregate(group=[{0}])
     LogicalJoin(condition=[<=>(CAST($0):VARCHAR, CAST($1):VARCHAR)], joinType=[anti])
       LogicalJoin(condition=[=(CAST($0):VARCHAR, $1)], joinType=[anti])
         LogicalProject(ENAME=[$1])
           LogicalFilter(condition=[=($7, 10)])
             LogicalTableScan(table=[[CATALOG, SALES, EMP]])
         LogicalProject(DEPTNO=[CAST($7):VARCHAR NOT NULL])
           LogicalFilter(condition=[OR(=($1, 'a'), =($1, 'b'))])
             LogicalTableScan(table=[[CATALOG, SALES, EMP]])
       LogicalProject(ENAME=[$1])
         LogicalTableScan(table=[[CATALOG, SALES, EMPNULLABLES]])