You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@carbondata.apache.org by "Jacky Li (JIRA)" <ji...@apache.org> on 2018/07/24 07:02:00 UTC

[jira] [Resolved] (CARBONDATA-2568) [MV] MV datamap is not hit when ,column is in group by but not in projection

     [ https://issues.apache.org/jira/browse/CARBONDATA-2568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Jacky Li resolved CARBONDATA-2568.
----------------------------------
       Resolution: Fixed
         Assignee: Ravindra Pesala  (was: xubo245)
    Fix Version/s: 1.4.1
                   1.5.0

> [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: Bug
>            Reporter: Babulal
>            Assignee: Ravindra Pesala
>            Priority: Major
>             Fix For: 1.5.0, 1.4.1
>
>
> 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)