[CARBONDATA-2531] [MV] MV not hit when alias is in use

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.5.0, 1.4.1
• Assignee: Bo Xu
• Reporter: Babulal
• Created: 24/May/18 17:51
• Updated: 24/Jul/18 11:28
• Resolved: 24/Jul/18 11:28

Description

#testcase class  

MVCreateTestCase 

 

CREATE TABLE fact5 (empname String, designation String, doj Timestamp, workgroupcategory int, workgroupcategoryname String, deptno int, deptname String, projectcode int, projectjoindate Timestamp, projectenddate Timestamp,attendance int, utilization int,salary int) STORED BY 'org.apache.carbondata.format'

LOAD DATA local inpath '/tmp/babu/data_big.csv' INTO TABLE fact5 OPTIONS('DELIMITER'= ',', 'QUOTECHAR'= '"','timestampformat'='dd-MM-yyyy');

create datamap datamap53 using 'mv' as select deptname, sum(salary) from fact4 group by deptname

 

0: jdbc:hive2://10.18.222.231:23040> explain select deptname, sum(salary) from fact4 as tt group by deptname;
------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+

plan

------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+

== Physical Plan == *BatchedScan CarbonDatasourceHadoopRelation [ Database name :default, Table name :datamap53_table, Schema :Some(StructType(StructField(fact4_deptname,StringType,true), StructField(sum_salary,LongType,true))) ] default.datamap53_tablefact4_deptname#1539,sum_salary#5961L

------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------–+

 

 

Now use alias for column name 

0: jdbc:hive2://10.18.222.231:23040> explain select deptname as babu, sum(salary) from fact4 as tt group by deptname;

plan

------------------------------------------------------------------------------------------------------------------+

== Physical Plan == *HashAggregate(keys=deptname#1539, functions=sum(cast(salary#1545 as bigint))) +- Exchange hashpartitioning(deptname#1539, 200) +- *HashAggregate(keys=deptname#1539, functions=partial_sum(cast(salary#1545 as bigint))) +- *BatchedScan CarbonDatasourceHadoopRelation [ Database name :default, Table name :fact4, Schema :Some(StructType(StructField(empname,StringType,true), StructField(designation,StringType,true), StructField(doj,TimestampType,true), StructField(workgroupcategory,IntegerType,true), StructField(workgroupcategoryname,StringType,true), StructField(deptno,IntegerType,true), StructField(deptname,StringType,true), StructField(projectcode,IntegerType,true), StructField(projectjoindate,TimestampType,true), StructField(projectenddate,TimestampType,true), StructField(attendance,IntegerType,true), StructField(utilization,IntegerType,true), StructField(salary,IntegerType,true))) ] default.fact4deptname#1539,salary#1545

+-----------------------------------------------------------------------------------------------------------------

 

Alias should be ignored data data should be fetched from MV table datamap53_table.

 

Issue Links

• is a child of: CARBONDATA-2628 Fix MV defects
• links to: GitHub Pull Request #2475