[ https://issues.apache.org/jira/browse/CARBONDATA-2568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xubo245 reassigned CARBONDATA-2568: ----------------------------------- Assignee: xubo245 > [MV] MV datamap is not hit when ,column is in group by but not in projection > ------------------------------------------------------------------------------ > > Key: CARBONDATA-2568 > URL: https://issues.apache.org/jira/browse/CARBONDATA-2568 > Project: CarbonData > Issue Type: Sub-task > Reporter: Babulal > Assignee: xubo245 > Priority: Major > > 0: jdbc:hive2://10.18.222.231:23040> create table mvtestcarbon10 (name_t1 string,age_t1 int,salray_t1 float,dob date,doj timestamp) stored by 'carbondata'; > +---------+--+ > | Result | > +---------+--+ > +---------+--+ > No rows selected (0.252 seconds) > 0: jdbc:hive2://10.18.222.231:23040> insert into mvtestcarbon10 select 'babu',12,25.25,'2014-01-01','2014-05-05 02:03:02'; > +---------+--+ > | Result | > +---------+--+ > +---------+--+ > No rows selected (21.893 seconds) > 0: jdbc:hive2://10.18.222.231:23040> create datamap mvtestcarbon10_map2 using 'mv' as select sum(salray_t1) from mvtestcarbon10 group by name_t1; > +---------+--+ > | Result | > +---------+--+ > +---------+--+ > No rows selected (0.525 seconds) > > 0: jdbc:hive2://10.18.222.231:23040> *explain select sum(salray_t1) from mvtestcarbon10 group by name_t1*; > | plan | > | == Physical Plan == > *HashAggregate(keys=[name_t1#2422], functions=[sum(salray_t1#2424)]) > +- Exchange hashpartitioning(name_t1#2422, 200) > +- *HashAggregate(keys=[name_t1#2422], functions=[partial_sum(salray_t1#2424)]) > +- *BatchedScan CarbonDatasourceHadoopRelation [ Database name :default, Table name :*mvtestcarbon10*, Schema :Some(StructType(StructField(name_t1,StringType,true), StructField(age_t1,IntegerType,true), StructField(salray_t1,DoubleType,true), StructField(dob,DateType,true), StructField(doj,TimestampType,true))) ] default.mvtestcarbon10[name_t1#2422,salray_t1#2424] | > > > 0: jdbc:hive2://10.18.222.231:23040> explain select sum(salray_t1) from mvtestcarbon10 ; > +----------------------------------------------------------------------------------------------------------------- > | plan | > +----------------------------------------------------------------------------------------------------------------- > | == Physical Plan == > *HashAggregate(keys=[], functions=[sum(salray_t1#2424)]) > +- Exchange SinglePartition > +- *HashAggregate(keys=[], functions=[partial_sum(salray_t1#2424)]) > +- *BatchedScan CarbonDatasourceHadoopRelation [ Database name :default, Table name :*mvtestcarbon10*, Schema :Some(StructType(StructField(name_t1,StringType,true), StructField(age_t1,IntegerType,true), StructField(salray_t1,DoubleType,true), StructField(dob,DateType,true), StructField(doj,TimestampType,true))) ] default.mvtestcarbon10[salray_t1#2424] | > +----------------------------------------------------------------------------------------------------------------- > -- This message was sent by Atlassian JIRA (v7.6.3#76005) |
Free forum by Nabble | Edit this page |