[ https://issues.apache.org/jira/browse/CARBONDATA-3752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ajantha Bhat resolved CARBONDATA-3752. -------------------------------------- Fix Version/s: 2.0.0 Resolution: Fixed > Query on carbon table should support reusing Exchange > ----------------------------------------------------- > > Key: CARBONDATA-3752 > URL: https://issues.apache.org/jira/browse/CARBONDATA-3752 > Project: CarbonData > Issue Type: Improvement > Reporter: David Cai > Priority: Major > Fix For: 2.0.0 > > Time Spent: 50m > Remaining Estimate: 0h > > Query on carbon table should support reusing Exchange > [Reproduce] > create table t1(c1 int, c2 string) using carbondata > insert into t1 values(1, 'abc') > explain > select c2, sum(c1) from t1 group by c2 > union all > select c2, sum(c1) from t1 group by c2 > [Physical Plan] > {noformat} > Union > :- *(2) HashAggregate(keys=[c2#37], functions=[sum(cast(c1#36 as bigint))]) > : +- Exchange hashpartitioning(c2#37, 200) > : +- *(1) HashAggregate(keys=[c2#37], functions=[partial_sum(cast(c1#36 as > bigint))]) > : +- *(1) FileScan carbondata default.t1[c1#36,c2#37] ReadSchema: > struct<c1:int,c2:string> > +- *(4) HashAggregate(keys=[c2#37], functions=[sum(cast(c1#36 as bigint))]) > +- Exchange hashpartitioning(c2#37, 200) > +- *(3) HashAggregate(keys=[c2#37], functions=[partial_sum(cast(c1#36 as > bigint))]) > +- *(3) FileScan carbondata default.t1[c1#36,c2#37] ReadSchema: > struct<c1:int,c2:string>{noformat} > It should reuse Exchange like Following: > {noformat} > Union > :- *(2) HashAggregate(keys=[c2#37], functions=[sum(cast(c1#36 as bigint))]) > : +- Exchange hashpartitioning(c2#37, 200) > : +- *(1) HashAggregate(keys=[c2#37], functions=[partial_sum(cast(c1#36 > as bigint))]) > : +- *(1) FileScan carbondata default.t1[c1#36,c2#37] ReadSchema: > struct<c1:int,c2:string> > +- *(4) HashAggregate(keys=[c2#37], functions=[sum(cast(c1#36 as bigint))]) > +- ReusedExchange [c2#37, sum#54L], Exchange hashpartitioning(c2#37, > 200){noformat} -- This message was sent by Atlassian Jira (v8.3.4#803005)