For the following types of queries, we should be able to push the filter
past the aggregate since the filter is on grouping column.

1. select o_custkey from cp.`tpch/orders.parquet` group by o_custkey having
o_custkey < 10;
2. select * from (select o_custkey from cp.`tpch/orders.parquet` group by
o_custkey) where o_custkey < 10;

  FilterRel(condition=[<($0, 10)])
    AggregateRel(group=[{0}])
      ProjectRel(o_custkey=[$1])
        EnumerableTableAccessRel(table=[[cp, tpch/orders.parquet]])


Should I create a JIRA for adding a new PushFilterPastAggregate rule ?  I
can work on it.

Aman

Reply via email to