import org.apache.calcite.rel.rules.ProjectFilterTransposeRule; //导入依赖的package包/类
@Test public void testPullFilterThroughAggregateGroupingSets()
    throws Exception {
  HepProgram preProgram = HepProgram.builder()
      .addRuleInstance(ProjectMergeRule.INSTANCE)
      .addRuleInstance(ProjectFilterTransposeRule.INSTANCE)
      .build();
  HepProgram program = HepProgram.builder()
      .addRuleInstance(AggregateFilterTransposeRule.INSTANCE)
      .build();
  final String sql = "select ename, sal, deptno from ("
      + "  select ename, sal, deptno"
      + "  from emp"
      + "  where sal > 5000)"
      + "group by rollup(ename, sal, deptno)";
  checkPlanning(tester, preProgram, new HepPlanner(program), sql);
}
 

import org.apache.calcite.rel.rules.ProjectFilterTransposeRule; //导入依赖的package包/类
/** Test case for
 * <a href="https://issues.apache.org/jira/browse/CALCITE-1778">[CALCITE-1778]
 * Query with "WHERE CASE" throws AssertionError "Cast for just nullability
 * not allowed"</a>. */
@Test public void testPushProjectPastFilter2() {
  final String sql = "select count(*)\n"
      + "from emp\n"
      + "where case when mgr < 10 then true else false end";
  sql(sql).withRule(ProjectFilterTransposeRule.INSTANCE).check();
}
 

import org.apache.calcite.rel.rules.ProjectFilterTransposeRule; //导入依赖的package包/类
@Test public void testPullFilterThroughAggregate() throws Exception {
  HepProgram preProgram = HepProgram.builder()
      .addRuleInstance(ProjectMergeRule.INSTANCE)
      .addRuleInstance(ProjectFilterTransposeRule.INSTANCE)
      .build();
  HepProgram program = HepProgram.builder()
      .addRuleInstance(AggregateFilterTransposeRule.INSTANCE)
      .build();
  final String sql = "select ename, sal, deptno from ("
      + "  select ename, sal, deptno"
      + "  from emp"
      + "  where sal > 5000)"
      + "group by ename, sal, deptno";
  checkPlanning(tester, preProgram, new HepPlanner(program), sql);
}
 

import org.apache.calcite.rel.rules.ProjectFilterTransposeRule; //导入依赖的package包/类
@Test public void testPushProjectPastFilter() {
  checkPlanning(ProjectFilterTransposeRule.INSTANCE,
      "select empno + deptno from emp where sal = 10 * comm "
          + "and upper(ename) = 'FOO'");
}