It's already there. You guys just need to upgrade. :) In 0.9.2, it's called PushFilterPastAggregateRule. In 1.0, it has been renamed to FilterAggregateTransposeRule.
On Tue, Nov 11, 2014 at 6:05 PM, Aman Sinha <[email protected]> wrote: > 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
