http://git-wip-us.apache.org/repos/asf/hive/blob/b356aae0/ql/src/test/results/clientpositive/llap/unionDistinct_1.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/llap/unionDistinct_1.q.out b/ql/src/test/results/clientpositive/llap/unionDistinct_1.q.out index cfae97f..d2eea6e 100644 --- a/ql/src/test/results/clientpositive/llap/unionDistinct_1.q.out +++ b/ql/src/test/results/clientpositive/llap/unionDistinct_1.q.out @@ -14,6 +14,8 @@ insert overwrite table tmptable_n9 UNION DISTINCT select 'tst3_n22' as key, count(1) as value from src s3) unionsrc PREHOOK: type: QUERY +PREHOOK: Input: default@src +PREHOOK: Output: default@tmptable_n9 POSTHOOK: query: explain insert overwrite table tmptable_n9 select unionsrc.key, unionsrc.value FROM (select 'tst1_n93' as key, count(1) as value from src s1 @@ -22,6 +24,8 @@ insert overwrite table tmptable_n9 UNION DISTINCT select 'tst3_n22' as key, count(1) as value from src s3) unionsrc POSTHOOK: type: QUERY +POSTHOOK: Input: default@src +POSTHOOK: Output: default@tmptable_n9 STAGE DEPENDENCIES: Stage-1 is a root stage Stage-2 depends on stages: Stage-1 @@ -284,6 +288,10 @@ insert overwrite table tmptable12 UNION DISTINCT select 'tst3_n22' as key, count(1) as value from srcbucket s3) unionsrc PREHOOK: type: QUERY +PREHOOK: Input: default@src +PREHOOK: Input: default@src1 +PREHOOK: Input: default@srcbucket +PREHOOK: Output: default@tmptable12 POSTHOOK: query: explain insert overwrite table tmptable12 select unionsrc.key, unionsrc.value FROM (select 'tst1_n93' as key, count(1) as value from src s1 @@ -292,6 +300,10 @@ insert overwrite table tmptable12 UNION DISTINCT select 'tst3_n22' as key, count(1) as value from srcbucket s3) unionsrc POSTHOOK: type: QUERY +POSTHOOK: Input: default@src +POSTHOOK: Input: default@src1 +POSTHOOK: Input: default@srcbucket +POSTHOOK: Output: default@tmptable12 STAGE DEPENDENCIES: Stage-1 is a root stage Stage-2 depends on stages: Stage-1 @@ -559,10 +571,14 @@ PREHOOK: query: explain select unionsrc.key, unionsrc.value FROM (select s1.key as key, s1.value as value from src s1 UNION DISTINCT select s2.key as key, s2.value as value from src s2) unionsrc PREHOOK: type: QUERY +PREHOOK: Input: default@src +PREHOOK: Output: hdfs://### HDFS PATH ### POSTHOOK: query: explain select unionsrc.key, unionsrc.value FROM (select s1.key as key, s1.value as value from src s1 UNION DISTINCT select s2.key as key, s2.value as value from src s2) unionsrc POSTHOOK: type: QUERY +POSTHOOK: Input: default@src +POSTHOOK: Output: hdfs://### HDFS PATH ### STAGE DEPENDENCIES: Stage-1 is a root stage Stage-0 depends on stages: Stage-1 @@ -983,6 +999,9 @@ FROM (select 'tst1_n93' as key, cast(count(1) as string) as value from src s1 INSERT OVERWRITE TABLE DEST1_n96 SELECT unionsrc.key, COUNT(DISTINCT SUBSTR(unionsrc.value,5)) GROUP BY unionsrc.key INSERT OVERWRITE TABLE DEST2_n26 SELECT unionsrc.key, unionsrc.value, COUNT(DISTINCT SUBSTR(unionsrc.value,5)) GROUP BY unionsrc.key, unionsrc.value PREHOOK: type: QUERY +PREHOOK: Input: default@src +PREHOOK: Output: default@dest1_n96 +PREHOOK: Output: default@dest2_n26 POSTHOOK: query: explain FROM (select 'tst1_n93' as key, cast(count(1) as string) as value from src s1 UNION DISTINCT @@ -990,6 +1009,9 @@ FROM (select 'tst1_n93' as key, cast(count(1) as string) as value from src s1 INSERT OVERWRITE TABLE DEST1_n96 SELECT unionsrc.key, COUNT(DISTINCT SUBSTR(unionsrc.value,5)) GROUP BY unionsrc.key INSERT OVERWRITE TABLE DEST2_n26 SELECT unionsrc.key, unionsrc.value, COUNT(DISTINCT SUBSTR(unionsrc.value,5)) GROUP BY unionsrc.key, unionsrc.value POSTHOOK: type: QUERY +POSTHOOK: Input: default@src +POSTHOOK: Output: default@dest1_n96 +POSTHOOK: Output: default@dest2_n26 STAGE DEPENDENCIES: Stage-2 is a root stage Stage-3 depends on stages: Stage-2 @@ -1908,6 +1930,9 @@ FROM (select 'tst1_n93' as key, cast(count(1) as string) as value from src s1 INSERT OVERWRITE TABLE DEST118 SELECT unionsrc.key, unionsrc.value INSERT OVERWRITE TABLE DEST218 SELECT unionsrc.key, unionsrc.value, unionsrc.value PREHOOK: type: QUERY +PREHOOK: Input: default@src +PREHOOK: Output: default@dest118 +PREHOOK: Output: default@dest218 POSTHOOK: query: explain FROM (select 'tst1_n93' as key, cast(count(1) as string) as value from src s1 UNION DISTINCT @@ -1915,6 +1940,9 @@ FROM (select 'tst1_n93' as key, cast(count(1) as string) as value from src s1 INSERT OVERWRITE TABLE DEST118 SELECT unionsrc.key, unionsrc.value INSERT OVERWRITE TABLE DEST218 SELECT unionsrc.key, unionsrc.value, unionsrc.value POSTHOOK: type: QUERY +POSTHOOK: Input: default@src +POSTHOOK: Output: default@dest118 +POSTHOOK: Output: default@dest218 STAGE DEPENDENCIES: Stage-2 is a root stage Stage-3 depends on stages: Stage-2 @@ -2802,6 +2830,9 @@ FROM (select 'tst1_n93' as key, cast(count(1) as string) as value from src s1 INSERT OVERWRITE TABLE DEST119 SELECT unionsrc.key, count(unionsrc.value) group by unionsrc.key INSERT OVERWRITE TABLE DEST219 SELECT unionsrc.key, unionsrc.value, unionsrc.value PREHOOK: type: QUERY +PREHOOK: Input: default@src +PREHOOK: Output: default@dest119 +PREHOOK: Output: default@dest219 POSTHOOK: query: explain FROM (select 'tst1_n93' as key, cast(count(1) as string) as value from src s1 UNION DISTINCT @@ -2809,6 +2840,9 @@ FROM (select 'tst1_n93' as key, cast(count(1) as string) as value from src s1 INSERT OVERWRITE TABLE DEST119 SELECT unionsrc.key, count(unionsrc.value) group by unionsrc.key INSERT OVERWRITE TABLE DEST219 SELECT unionsrc.key, unionsrc.value, unionsrc.value POSTHOOK: type: QUERY +POSTHOOK: Input: default@src +POSTHOOK: Output: default@dest119 +POSTHOOK: Output: default@dest219 STAGE DEPENDENCIES: Stage-2 is a root stage Stage-3 depends on stages: Stage-2 @@ -3742,6 +3776,11 @@ where a.k1 > 20 ) subq PREHOOK: type: QUERY +PREHOOK: Input: default@dst_union22_delta_n0 +PREHOOK: Input: default@dst_union22_delta_n0@ds=1 +PREHOOK: Input: default@dst_union22_n0 +PREHOOK: Input: default@dst_union22_n0@ds=1 +PREHOOK: Output: default@dst_union22_n0@ds=2 POSTHOOK: query: explain extended insert overwrite table dst_union22_n0 partition (ds='2') select * from @@ -3755,6 +3794,11 @@ where a.k1 > 20 ) subq POSTHOOK: type: QUERY +POSTHOOK: Input: default@dst_union22_delta_n0 +POSTHOOK: Input: default@dst_union22_delta_n0@ds=1 +POSTHOOK: Input: default@dst_union22_n0 +POSTHOOK: Input: default@dst_union22_n0@ds=1 +POSTHOOK: Output: default@dst_union22_n0@ds=2 OPTIMIZED SQL: SELECT `k1`, `k2`, `k3`, `k4` FROM (SELECT `k1`, `k2`, `k3`, `k4` FROM `default`.`dst_union22_delta_n0` @@ -4580,6 +4624,8 @@ from ( UNION DISTINCT select key as key2, value as value2 from src) s PREHOOK: type: QUERY +PREHOOK: Input: default@src +PREHOOK: Output: hdfs://### HDFS PATH ### POSTHOOK: query: explain select s.key2, s.value2 from ( @@ -4588,6 +4634,8 @@ from ( UNION DISTINCT select key as key2, value as value2 from src) s POSTHOOK: type: QUERY +POSTHOOK: Input: default@src +POSTHOOK: Output: hdfs://### HDFS PATH ### STAGE DEPENDENCIES: Stage-1 is a root stage Stage-0 depends on stages: Stage-1 @@ -5058,6 +5106,11 @@ select s.key, s.count from ( select key, count(1) as count from src5_n1 where key < 10 group by key )s PREHOOK: type: QUERY +PREHOOK: Input: default@src2_n2 +PREHOOK: Input: default@src3 +PREHOOK: Input: default@src4 +PREHOOK: Input: default@src5_n1 +PREHOOK: Output: hdfs://### HDFS PATH ### POSTHOOK: query: explain extended select s.key, s.count from ( select key, count from src2_n2 where key < 10 @@ -5069,6 +5122,11 @@ select s.key, s.count from ( select key, count(1) as count from src5_n1 where key < 10 group by key )s POSTHOOK: type: QUERY +POSTHOOK: Input: default@src2_n2 +POSTHOOK: Input: default@src3 +POSTHOOK: Input: default@src4 +POSTHOOK: Input: default@src5_n1 +POSTHOOK: Output: hdfs://### HDFS PATH ### OPTIMIZED SQL: SELECT `key`, `count` FROM (SELECT `key`, `count` FROM (SELECT `key`, `count` @@ -5597,6 +5655,11 @@ select s.key, s.count from ( select a.key as key, b.count as count from src4 a join src5_n1 b on a.key=b.key where a.key < 10 )s PREHOOK: type: QUERY +PREHOOK: Input: default@src2_n2 +PREHOOK: Input: default@src3 +PREHOOK: Input: default@src4 +PREHOOK: Input: default@src5_n1 +PREHOOK: Output: hdfs://### HDFS PATH ### POSTHOOK: query: explain extended select s.key, s.count from ( select key, count from src2_n2 where key < 10 @@ -5606,6 +5669,11 @@ select s.key, s.count from ( select a.key as key, b.count as count from src4 a join src5_n1 b on a.key=b.key where a.key < 10 )s POSTHOOK: type: QUERY +POSTHOOK: Input: default@src2_n2 +POSTHOOK: Input: default@src3 +POSTHOOK: Input: default@src4 +POSTHOOK: Input: default@src5_n1 +POSTHOOK: Output: hdfs://### HDFS PATH ### OPTIMIZED SQL: SELECT `key`, `count` FROM (SELECT `key`, `count` FROM (SELECT `key`, `count` @@ -6098,6 +6166,11 @@ select s.key, s.count from ( select a.key as key, count(1) as count from src4 a join src5_n1 b on a.key=b.key where a.key < 10 group by a.key )s PREHOOK: type: QUERY +PREHOOK: Input: default@src2_n2 +PREHOOK: Input: default@src3 +PREHOOK: Input: default@src4 +PREHOOK: Input: default@src5_n1 +PREHOOK: Output: hdfs://### HDFS PATH ### POSTHOOK: query: explain extended select s.key, s.count from ( select key, count from src2_n2 where key < 10 @@ -6107,6 +6180,11 @@ select s.key, s.count from ( select a.key as key, count(1) as count from src4 a join src5_n1 b on a.key=b.key where a.key < 10 group by a.key )s POSTHOOK: type: QUERY +POSTHOOK: Input: default@src2_n2 +POSTHOOK: Input: default@src3 +POSTHOOK: Input: default@src4 +POSTHOOK: Input: default@src5_n1 +POSTHOOK: Output: hdfs://### HDFS PATH ### OPTIMIZED SQL: SELECT `key`, `count` FROM (SELECT `key`, `count` FROM (SELECT `key`, `count` @@ -6654,6 +6732,12 @@ FROM ) master_table ) a GROUP BY key, value PREHOOK: type: CREATETABLE_AS_SELECT +PREHOOK: Input: default@srcpart +PREHOOK: Input: default@srcpart@ds=2008-04-08/hr=11 +PREHOOK: Input: default@tmp_srcpart_n0 +PREHOOK: Input: default@tmp_srcpart_n0@ds=2008-04-08/hr=11 +PREHOOK: Output: database:default +PREHOOK: Output: default@tmp_unionall_n0 POSTHOOK: query: explain create table tmp_unionall_n0 as SELECT count(1) as counts, key, value @@ -6672,6 +6756,12 @@ FROM ) master_table ) a GROUP BY key, value POSTHOOK: type: CREATETABLE_AS_SELECT +POSTHOOK: Input: default@srcpart +POSTHOOK: Input: default@srcpart@ds=2008-04-08/hr=11 +POSTHOOK: Input: default@tmp_srcpart_n0 +POSTHOOK: Input: default@tmp_srcpart_n0@ds=2008-04-08/hr=11 +POSTHOOK: Output: database:default +POSTHOOK: Output: default@tmp_unionall_n0 STAGE DEPENDENCIES: Stage-1 is a root stage Stage-2 depends on stages: Stage-1 @@ -6857,6 +6947,10 @@ WHERE ds='2008-04-08' and hr='11' ) a group by key, value PREHOOK: type: QUERY +PREHOOK: Input: default@srcpart +PREHOOK: Input: default@srcpart@ds=2008-04-08/hr=11 +PREHOOK: Input: default@srcpart@ds=2008-04-08/hr=12 +PREHOOK: Output: hdfs://### HDFS PATH ### POSTHOOK: query: EXPLAIN SELECT count(1) as counts, @@ -6879,6 +6973,10 @@ WHERE ds='2008-04-08' and hr='11' ) a group by key, value POSTHOOK: type: QUERY +POSTHOOK: Input: default@srcpart +POSTHOOK: Input: default@srcpart@ds=2008-04-08/hr=11 +POSTHOOK: Input: default@srcpart@ds=2008-04-08/hr=12 +POSTHOOK: Output: hdfs://### HDFS PATH ### STAGE DEPENDENCIES: Stage-1 is a root stage Stage-0 depends on stages: Stage-1 @@ -8138,8 +8236,16 @@ POSTHOOK: Lineage: jackson_sev_add.key SIMPLE [(src)src.FieldSchema(name:key, ty POSTHOOK: Lineage: jackson_sev_add.value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: explain select b.* from jackson_sev_same a join (select * from dim_pho UNION DISTINCT select * from jackson_sev_add)b on a.key=b.key and b.key=97 PREHOOK: type: QUERY +PREHOOK: Input: default@dim_pho +PREHOOK: Input: default@jackson_sev_add +PREHOOK: Input: default@jackson_sev_same +PREHOOK: Output: hdfs://### HDFS PATH ### POSTHOOK: query: explain select b.* from jackson_sev_same a join (select * from dim_pho UNION DISTINCT select * from jackson_sev_add)b on a.key=b.key and b.key=97 POSTHOOK: type: QUERY +POSTHOOK: Input: default@dim_pho +POSTHOOK: Input: default@jackson_sev_add +POSTHOOK: Input: default@jackson_sev_same +POSTHOOK: Output: hdfs://### HDFS PATH ### STAGE DEPENDENCIES: Stage-1 is a root stage Stage-0 depends on stages: Stage-1 @@ -8298,6 +8404,8 @@ select * from ( ) subq ) a PREHOOK: type: QUERY +PREHOOK: Input: default@src +PREHOOK: Output: default@union_subq_union_n0 POSTHOOK: query: explain insert overwrite table union_subq_union_n0 select * from ( @@ -8311,6 +8419,8 @@ select * from ( ) subq ) a POSTHOOK: type: QUERY +POSTHOOK: Input: default@src +POSTHOOK: Output: default@union_subq_union_n0 STAGE DEPENDENCIES: Stage-1 is a root stage Stage-2 depends on stages: Stage-1 @@ -8607,6 +8717,8 @@ select * from ( ) subq ) a PREHOOK: type: QUERY +PREHOOK: Input: default@src +PREHOOK: Output: default@union_subq_union29 POSTHOOK: query: explain insert overwrite table union_subq_union29 select * from ( @@ -8620,6 +8732,8 @@ select * from ( ) subq ) a POSTHOOK: type: QUERY +POSTHOOK: Input: default@src +POSTHOOK: Output: default@union_subq_union29 STAGE DEPENDENCIES: Stage-1 is a root stage Stage-2 depends on stages: Stage-1 @@ -8866,6 +8980,8 @@ FROM ( CLUSTER BY id ) a PREHOOK: type: QUERY +PREHOOK: Input: default@src +PREHOOK: Output: hdfs://### HDFS PATH ### POSTHOOK: query: explain SELECT * FROM ( @@ -8883,6 +8999,8 @@ FROM ( CLUSTER BY id ) a POSTHOOK: type: QUERY +POSTHOOK: Input: default@src +POSTHOOK: Output: hdfs://### HDFS PATH ### STAGE DEPENDENCIES: Stage-1 is a root stage Stage-0 depends on stages: Stage-1 @@ -9166,6 +9284,8 @@ UNION DISTINCT select key, value from src ) aa PREHOOK: type: QUERY +PREHOOK: Input: default@src +PREHOOK: Output: default@union_subq_union30 POSTHOOK: query: explain insert overwrite table union_subq_union30 select * from ( @@ -9186,6 +9306,8 @@ UNION DISTINCT select key, value from src ) aa POSTHOOK: type: QUERY +POSTHOOK: Input: default@src +POSTHOOK: Output: default@union_subq_union30 STAGE DEPENDENCIES: Stage-1 is a root stage Stage-2 depends on stages: Stage-1 @@ -9576,6 +9698,10 @@ insert overwrite table t3_n22 insert overwrite table t4_n11 select value, count(1) group by value PREHOOK: type: QUERY +PREHOOK: Input: default@t1_n93 +PREHOOK: Input: default@t2_n58 +PREHOOK: Output: default@t3_n22 +PREHOOK: Output: default@t4_n11 POSTHOOK: query: explain from (select * from t1_n93 @@ -9587,6 +9713,10 @@ insert overwrite table t3_n22 insert overwrite table t4_n11 select value, count(1) group by value POSTHOOK: type: QUERY +POSTHOOK: Input: default@t1_n93 +POSTHOOK: Input: default@t2_n58 +POSTHOOK: Output: default@t3_n22 +POSTHOOK: Output: default@t4_n11 STAGE DEPENDENCIES: Stage-2 is a root stage Stage-3 depends on stages: Stage-2 @@ -9897,6 +10027,10 @@ insert overwrite table t5_n4 insert overwrite table t6_n3 select c1, sum(cnt) group by c1 PREHOOK: type: QUERY +PREHOOK: Input: default@t1_n93 +PREHOOK: Input: default@t2_n58 +PREHOOK: Output: default@t5_n4 +PREHOOK: Output: default@t6_n3 POSTHOOK: query: explain from ( @@ -9909,6 +10043,10 @@ insert overwrite table t5_n4 insert overwrite table t6_n3 select c1, sum(cnt) group by c1 POSTHOOK: type: QUERY +POSTHOOK: Input: default@t1_n93 +POSTHOOK: Input: default@t2_n58 +POSTHOOK: Output: default@t5_n4 +POSTHOOK: Output: default@t6_n3 STAGE DEPENDENCIES: Stage-2 is a root stage Stage-3 depends on stages: Stage-2 @@ -10264,6 +10402,10 @@ insert overwrite table t7_n4 insert overwrite table t8_n2 select c1, count(1) group by c1 PREHOOK: type: QUERY +PREHOOK: Input: default@t1_n93 +PREHOOK: Input: default@t9_n1 +PREHOOK: Output: default@t7_n4 +PREHOOK: Output: default@t8_n2 POSTHOOK: query: explain from ( @@ -10276,6 +10418,10 @@ insert overwrite table t7_n4 insert overwrite table t8_n2 select c1, count(1) group by c1 POSTHOOK: type: QUERY +POSTHOOK: Input: default@t1_n93 +POSTHOOK: Input: default@t9_n1 +POSTHOOK: Output: default@t7_n4 +POSTHOOK: Output: default@t8_n2 STAGE DEPENDENCIES: Stage-2 is a root stage Stage-3 depends on stages: Stage-2 @@ -10579,12 +10725,18 @@ SELECT * FROM UNION DISTINCT SELECT CAST(key AS BIGINT) AS key FROM t2_n58) a PREHOOK: type: QUERY +PREHOOK: Input: default@t1_n93 +PREHOOK: Input: default@t2_n58 +PREHOOK: Output: hdfs://### HDFS PATH ### POSTHOOK: query: EXPLAIN SELECT * FROM (SELECT CAST(key AS DOUBLE) AS key FROM t1_n93 UNION DISTINCT SELECT CAST(key AS BIGINT) AS key FROM t2_n58) a POSTHOOK: type: QUERY +POSTHOOK: Input: default@t1_n93 +POSTHOOK: Input: default@t2_n58 +POSTHOOK: Output: hdfs://### HDFS PATH ### STAGE DEPENDENCIES: Stage-1 is a root stage Stage-0 depends on stages: Stage-1 @@ -10691,12 +10843,18 @@ SELECT * FROM UNION DISTINCT SELECT CAST(key AS DOUBLE) AS key FROM t2_n58) a PREHOOK: type: QUERY +PREHOOK: Input: default@t1_n93 +PREHOOK: Input: default@t2_n58 +PREHOOK: Output: hdfs://### HDFS PATH ### POSTHOOK: query: EXPLAIN SELECT * FROM (SELECT CAST(a.key AS BIGINT) AS key FROM t1_n93 a JOIN t2_n58 b ON a.key = b.key UNION DISTINCT SELECT CAST(key AS DOUBLE) AS key FROM t2_n58) a POSTHOOK: type: QUERY +POSTHOOK: Input: default@t1_n93 +POSTHOOK: Input: default@t2_n58 +POSTHOOK: Output: hdfs://### HDFS PATH ### STAGE DEPENDENCIES: Stage-1 is a root stage Stage-0 depends on stages: Stage-1 @@ -10839,12 +10997,18 @@ SELECT * FROM UNION DISTINCT SELECT CAST(a.key AS BIGINT) AS key FROM t1_n93 a JOIN t2_n58 b ON a.key = b.key) a PREHOOK: type: QUERY +PREHOOK: Input: default@t1_n93 +PREHOOK: Input: default@t2_n58 +PREHOOK: Output: hdfs://### HDFS PATH ### POSTHOOK: query: EXPLAIN SELECT * FROM (SELECT CAST(key AS DOUBLE) AS key FROM t2_n58 UNION DISTINCT SELECT CAST(a.key AS BIGINT) AS key FROM t1_n93 a JOIN t2_n58 b ON a.key = b.key) a POSTHOOK: type: QUERY +POSTHOOK: Input: default@t1_n93 +POSTHOOK: Input: default@t2_n58 +POSTHOOK: Output: hdfs://### HDFS PATH ### STAGE DEPENDENCIES: Stage-1 is a root stage Stage-0 depends on stages: Stage-1 @@ -10987,12 +11151,18 @@ SELECT * FROM UNION DISTINCT SELECT CAST(key AS DOUBLE) AS key, CAST(key AS STRING) AS value FROM t2_n58) a PREHOOK: type: QUERY +PREHOOK: Input: default@t1_n93 +PREHOOK: Input: default@t2_n58 +PREHOOK: Output: hdfs://### HDFS PATH ### POSTHOOK: query: EXPLAIN SELECT * FROM (SELECT CAST(a.key AS BIGINT) AS key, CAST(b.key AS STRING) AS value FROM t1_n93 a JOIN t2_n58 b ON a.key = b.key UNION DISTINCT SELECT CAST(key AS DOUBLE) AS key, CAST(key AS STRING) AS value FROM t2_n58) a POSTHOOK: type: QUERY +POSTHOOK: Input: default@t1_n93 +POSTHOOK: Input: default@t2_n58 +POSTHOOK: Output: hdfs://### HDFS PATH ### STAGE DEPENDENCIES: Stage-1 is a root stage Stage-0 depends on stages: Stage-1 @@ -11135,12 +11305,18 @@ SELECT * FROM UNION DISTINCT SELECT CAST(a.key AS BIGINT) AS key, CAST(b.key AS VARCHAR(20)) AS value FROM t1_n93 a JOIN t2_n58 b ON a.key = b.key) a PREHOOK: type: QUERY +PREHOOK: Input: default@t1_n93 +PREHOOK: Input: default@t2_n58 +PREHOOK: Output: hdfs://### HDFS PATH ### POSTHOOK: query: EXPLAIN SELECT * FROM (SELECT CAST(key AS DOUBLE) AS key, CAST(key AS STRING) AS value FROM t2_n58 UNION DISTINCT SELECT CAST(a.key AS BIGINT) AS key, CAST(b.key AS VARCHAR(20)) AS value FROM t1_n93 a JOIN t2_n58 b ON a.key = b.key) a POSTHOOK: type: QUERY +POSTHOOK: Input: default@t1_n93 +POSTHOOK: Input: default@t2_n58 +POSTHOOK: Output: hdfs://### HDFS PATH ### STAGE DEPENDENCIES: Stage-1 is a root stage Stage-0 depends on stages: Stage-1 @@ -11298,6 +11474,8 @@ UNION DISTINCT GROUP BY key )a PREHOOK: type: QUERY +PREHOOK: Input: default@src +PREHOOK: Output: default@test_src POSTHOOK: query: EXPLAIN INSERT OVERWRITE TABLE test_src SELECT key, value FROM ( SELECT key, value FROM src @@ -11307,6 +11485,8 @@ UNION DISTINCT GROUP BY key )a POSTHOOK: type: QUERY +POSTHOOK: Input: default@src +POSTHOOK: Output: default@test_src STAGE DEPENDENCIES: Stage-1 is a root stage Stage-2 depends on stages: Stage-1 @@ -11502,6 +11682,8 @@ UNION DISTINCT WHERE key = 0 )a PREHOOK: type: QUERY +PREHOOK: Input: default@src +PREHOOK: Output: default@test_src POSTHOOK: query: EXPLAIN INSERT OVERWRITE TABLE test_src SELECT key, value FROM ( SELECT key, cast(COUNT(*) as string) AS value FROM src @@ -11511,6 +11693,8 @@ UNION DISTINCT WHERE key = 0 )a POSTHOOK: type: QUERY +POSTHOOK: Input: default@src +POSTHOOK: Output: default@test_src STAGE DEPENDENCIES: Stage-1 is a root stage Stage-2 depends on stages: Stage-1 @@ -11802,6 +11986,11 @@ SELECT * FROM ( SELECT key,value FROM (SELECT * FROM (SELECT * FROM src10_3) sub2 UNION DISTINCT SELECT * FROM src10_4 ) alias0 ) alias1 PREHOOK: type: QUERY +PREHOOK: Input: default@src10_1 +PREHOOK: Input: default@src10_2 +PREHOOK: Input: default@src10_3 +PREHOOK: Input: default@src10_4 +PREHOOK: Output: hdfs://### HDFS PATH ### POSTHOOK: query: explain SELECT * FROM ( SELECT sub1.key,sub1.value FROM (SELECT * FROM src10_1) sub1 JOIN (SELECT * FROM src10_2) sub0 ON (sub0.key = sub1.key) @@ -11809,6 +11998,11 @@ SELECT * FROM ( SELECT key,value FROM (SELECT * FROM (SELECT * FROM src10_3) sub2 UNION DISTINCT SELECT * FROM src10_4 ) alias0 ) alias1 POSTHOOK: type: QUERY +POSTHOOK: Input: default@src10_1 +POSTHOOK: Input: default@src10_2 +POSTHOOK: Input: default@src10_3 +POSTHOOK: Input: default@src10_4 +POSTHOOK: Output: hdfs://### HDFS PATH ### STAGE DEPENDENCIES: Stage-1 is a root stage Stage-0 depends on stages: Stage-1 @@ -12000,6 +12194,11 @@ SELECT * FROM ( SELECT key,value FROM (SELECT * FROM (SELECT * FROM src10_3) sub2 UNION DISTINCT SELECT * FROM src10_4 ) alias0 ) alias1 PREHOOK: type: QUERY +PREHOOK: Input: default@src10_1 +PREHOOK: Input: default@src10_2 +PREHOOK: Input: default@src10_3 +PREHOOK: Input: default@src10_4 +PREHOOK: Output: hdfs://### HDFS PATH ### POSTHOOK: query: explain SELECT * FROM ( SELECT sub1.key,sub1.value FROM (SELECT * FROM src10_1) sub1 JOIN (SELECT * FROM src10_2) sub0 ON (sub0.key = sub1.key) @@ -12007,6 +12206,11 @@ SELECT * FROM ( SELECT key,value FROM (SELECT * FROM (SELECT * FROM src10_3) sub2 UNION DISTINCT SELECT * FROM src10_4 ) alias0 ) alias1 POSTHOOK: type: QUERY +POSTHOOK: Input: default@src10_1 +POSTHOOK: Input: default@src10_2 +POSTHOOK: Input: default@src10_3 +POSTHOOK: Input: default@src10_4 +POSTHOOK: Output: hdfs://### HDFS PATH ### STAGE DEPENDENCIES: Stage-1 is a root stage Stage-0 depends on stages: Stage-1
http://git-wip-us.apache.org/repos/asf/hive/blob/b356aae0/ql/src/test/results/clientpositive/llap/unionDistinct_3.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/llap/unionDistinct_3.q.out b/ql/src/test/results/clientpositive/llap/unionDistinct_3.q.out index 4624cc2..4d3d71d 100644 --- a/ql/src/test/results/clientpositive/llap/unionDistinct_3.q.out +++ b/ql/src/test/results/clientpositive/llap/unionDistinct_3.q.out @@ -2,10 +2,14 @@ PREHOOK: query: explain select count(1) FROM (select s1.key as key, s1.value as value from src s1 UNION DISTINCT select s2.key as key, s2.value as value from src s2) unionsrc PREHOOK: type: QUERY +PREHOOK: Input: default@src +#### A masked pattern was here #### POSTHOOK: query: explain select count(1) FROM (select s1.key as key, s1.value as value from src s1 UNION DISTINCT select s2.key as key, s2.value as value from src s2) unionsrc POSTHOOK: type: QUERY +POSTHOOK: Input: default@src +#### A masked pattern was here #### STAGE DEPENDENCIES: Stage-1 is a root stage Stage-0 depends on stages: Stage-1 @@ -135,12 +139,18 @@ insert overwrite table tmptable_n0 UNION DISTINCT select s2.key as key, s2.value as value from src1 s2) unionsrc PREHOOK: type: QUERY +PREHOOK: Input: default@src +PREHOOK: Input: default@src1 +PREHOOK: Output: default@tmptable_n0 POSTHOOK: query: explain insert overwrite table tmptable_n0 select unionsrc.key, unionsrc.value FROM (select 'tst1' as key, cast(count(1) as string) as value from src s1 UNION DISTINCT select s2.key as key, s2.value as value from src1 s2) unionsrc POSTHOOK: type: QUERY +POSTHOOK: Input: default@src +POSTHOOK: Input: default@src1 +POSTHOOK: Output: default@tmptable_n0 STAGE DEPENDENCIES: Stage-1 is a root stage Stage-2 depends on stages: Stage-1 @@ -349,11 +359,15 @@ PREHOOK: query: explain select s2.key as key, s2.value as value from src s2 UNION DISTINCT select s3.key as key, s3.value as value from src s3) unionsrc PREHOOK: type: QUERY +PREHOOK: Input: default@src +#### A masked pattern was here #### POSTHOOK: query: explain select unionsrc.key, unionsrc.value FROM (select s1.key as key, s1.value as value from src s1 UNION DISTINCT select s2.key as key, s2.value as value from src s2 UNION DISTINCT select s3.key as key, s3.value as value from src s3) unionsrc POSTHOOK: type: QUERY +POSTHOOK: Input: default@src +#### A masked pattern was here #### STAGE DEPENDENCIES: Stage-1 is a root stage Stage-0 depends on stages: Stage-1 @@ -805,6 +819,8 @@ PREHOOK: query: explain UNION DISTINCT select 'tst3' as key, count(1) as value from src s3) unionsrc group by unionsrc.key PREHOOK: type: QUERY +PREHOOK: Input: default@src +#### A masked pattern was here #### POSTHOOK: query: explain select unionsrc.key, count(1) FROM (select 'tst1' as key, count(1) as value from src s1 UNION DISTINCT @@ -812,6 +828,8 @@ POSTHOOK: query: explain UNION DISTINCT select 'tst3' as key, count(1) as value from src s3) unionsrc group by unionsrc.key POSTHOOK: type: QUERY +POSTHOOK: Input: default@src +#### A masked pattern was here #### STAGE DEPENDENCIES: Stage-1 is a root stage Stage-0 depends on stages: Stage-1 @@ -1013,12 +1031,18 @@ PREHOOK: query: explain select 'tst1' as key, cast(count(1) as string) as value from src s1) unionsrc group by unionsrc.key PREHOOK: type: QUERY +PREHOOK: Input: default@src +PREHOOK: Input: default@src1 +#### A masked pattern was here #### POSTHOOK: query: explain select unionsrc.key, count(1) FROM (select s2.key as key, s2.value as value from src1 s2 UNION DISTINCT select 'tst1' as key, cast(count(1) as string) as value from src s1) unionsrc group by unionsrc.key POSTHOOK: type: QUERY +POSTHOOK: Input: default@src +POSTHOOK: Input: default@src1 +#### A masked pattern was here #### STAGE DEPENDENCIES: Stage-1 is a root stage Stage-0 depends on stages: Stage-1 @@ -1168,6 +1192,9 @@ PREHOOK: query: explain UNION DISTINCT select s3.key as key, s3.value as value from src1 s3) unionsrc group by unionsrc.key PREHOOK: type: QUERY +PREHOOK: Input: default@src +PREHOOK: Input: default@src1 +#### A masked pattern was here #### POSTHOOK: query: explain select unionsrc.key, count(1) FROM (select 'tst1' as key, cast(count(1) as string) as value from src s1 UNION DISTINCT @@ -1175,6 +1202,9 @@ POSTHOOK: query: explain UNION DISTINCT select s3.key as key, s3.value as value from src1 s3) unionsrc group by unionsrc.key POSTHOOK: type: QUERY +POSTHOOK: Input: default@src +POSTHOOK: Input: default@src1 +#### A masked pattern was here #### STAGE DEPENDENCIES: Stage-1 is a root stage Stage-0 depends on stages: Stage-1 @@ -1370,6 +1400,8 @@ SELECT count(1) FROM ( SELECT key, value FROM src UNION DISTINCT SELECT key, value FROM src) src PREHOOK: type: QUERY +PREHOOK: Input: default@src +#### A masked pattern was here #### POSTHOOK: query: EXPLAIN SELECT count(1) FROM ( SELECT key, value FROM src UNION DISTINCT @@ -1378,6 +1410,8 @@ SELECT count(1) FROM ( SELECT key, value FROM src UNION DISTINCT SELECT key, value FROM src) src POSTHOOK: type: QUERY +POSTHOOK: Input: default@src +#### A masked pattern was here #### STAGE DEPENDENCIES: Stage-1 is a root stage Stage-0 depends on stages: Stage-1 @@ -1637,6 +1671,8 @@ JOIN select s4.key as key, s4.value as value from src s4 where s4.key < 10) unionsrc2 ON (unionsrc1.key = unionsrc2.key) PREHOOK: type: QUERY +PREHOOK: Input: default@src +#### A masked pattern was here #### POSTHOOK: query: explain SELECT unionsrc1.key, unionsrc1.value, unionsrc2.key, unionsrc2.value FROM (select 'tst1' as key, cast(count(1) as string) as value from src s1 @@ -1648,6 +1684,8 @@ JOIN select s4.key as key, s4.value as value from src s4 where s4.key < 10) unionsrc2 ON (unionsrc1.key = unionsrc2.key) POSTHOOK: type: QUERY +POSTHOOK: Input: default@src +#### A masked pattern was here #### STAGE DEPENDENCIES: Stage-1 is a root stage Stage-0 depends on stages: Stage-1 @@ -1881,6 +1919,9 @@ FROM ( ) union_output GROUP BY key PREHOOK: type: QUERY +PREHOOK: Input: default@src +PREHOOK: Input: default@src_thrift +#### A masked pattern was here #### POSTHOOK: query: explain SELECT key, count(1) FROM ( @@ -1896,6 +1937,9 @@ FROM ( ) union_output GROUP BY key POSTHOOK: type: QUERY +POSTHOOK: Input: default@src +POSTHOOK: Input: default@src_thrift +#### A masked pattern was here #### STAGE DEPENDENCIES: Stage-1 is a root stage Stage-0 depends on stages: Stage-1 http://git-wip-us.apache.org/repos/asf/hive/blob/b356aae0/ql/src/test/results/clientpositive/llap/union_assertion_type.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/llap/union_assertion_type.q.out b/ql/src/test/results/clientpositive/llap/union_assertion_type.q.out index e424664..21d3d11 100644 --- a/ql/src/test/results/clientpositive/llap/union_assertion_type.q.out +++ b/ql/src/test/results/clientpositive/llap/union_assertion_type.q.out @@ -43,6 +43,9 @@ UNION ALL SELECT column1, column2, '5' as column3 FROM union_table_test_n1) x WHERE x.column3 < '5' PREHOOK: type: QUERY +PREHOOK: Input: default@union_table_test_n0 +PREHOOK: Input: default@union_table_test_n1 +#### A masked pattern was here #### POSTHOOK: query: EXPLAIN SELECT column1, x.column2, x.column3 FROM ( SELECT column1, column2, column3 FROM union_table_test_n0 @@ -50,6 +53,9 @@ UNION ALL SELECT column1, column2, '5' as column3 FROM union_table_test_n1) x WHERE x.column3 < '5' POSTHOOK: type: QUERY +POSTHOOK: Input: default@union_table_test_n0 +POSTHOOK: Input: default@union_table_test_n1 +#### A masked pattern was here #### STAGE DEPENDENCIES: Stage-0 is a root stage @@ -94,6 +100,9 @@ UNION ALL SELECT column1, column2, '5' as column3 FROM union_table_test_n0) x WHERE x.column3 < '5' PREHOOK: type: QUERY +PREHOOK: Input: default@union_table_test_n0 +PREHOOK: Input: default@union_table_test_n1 +#### A masked pattern was here #### POSTHOOK: query: EXPLAIN SELECT column1, x.column2, x.column3 FROM ( SELECT column1, column2, '5' as column3 FROM union_table_test_n1 @@ -101,6 +110,9 @@ UNION ALL SELECT column1, column2, '5' as column3 FROM union_table_test_n0) x WHERE x.column3 < '5' POSTHOOK: type: QUERY +POSTHOOK: Input: default@union_table_test_n0 +POSTHOOK: Input: default@union_table_test_n1 +#### A masked pattern was here #### STAGE DEPENDENCIES: Stage-0 is a root stage @@ -211,6 +223,10 @@ SELECT u0.k as key, u0.d1 as data0, u0.d2 as data2 FROM ( SELECT k,'' as d1,'' as d2 FROM union_table_test_n4) u0 LEFT OUTER JOIN union_table_test_n5 tx1 ON (u0.k = tx1.k AND tx1.k != d1) AND u0.k!=1 PREHOOK: type: QUERY +PREHOOK: Input: default@union_table_test_n3 +PREHOOK: Input: default@union_table_test_n4 +PREHOOK: Input: default@union_table_test_n5 +#### A masked pattern was here #### POSTHOOK: query: EXPLAIN SELECT u0.k as key, u0.d1 as data0, u0.d2 as data2 FROM ( SELECT k,'' as d1,'' as d2 FROM union_table_test_n3 @@ -218,6 +234,10 @@ SELECT u0.k as key, u0.d1 as data0, u0.d2 as data2 FROM ( SELECT k,'' as d1,'' as d2 FROM union_table_test_n4) u0 LEFT OUTER JOIN union_table_test_n5 tx1 ON (u0.k = tx1.k AND tx1.k != d1) AND u0.k!=1 POSTHOOK: type: QUERY +POSTHOOK: Input: default@union_table_test_n3 +POSTHOOK: Input: default@union_table_test_n4 +POSTHOOK: Input: default@union_table_test_n5 +#### A masked pattern was here #### STAGE DEPENDENCIES: Stage-1 is a root stage Stage-0 depends on stages: Stage-1 http://git-wip-us.apache.org/repos/asf/hive/blob/b356aae0/ql/src/test/results/clientpositive/llap/union_remove_26.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/llap/union_remove_26.q.out b/ql/src/test/results/clientpositive/llap/union_remove_26.q.out index b60c107..b4b8b3e 100644 --- a/ql/src/test/results/clientpositive/llap/union_remove_26.q.out +++ b/ql/src/test/results/clientpositive/llap/union_remove_26.q.out @@ -127,6 +127,10 @@ PREHOOK: query: explain UNION ALL SELECT count(1) as rowcnt, min(val) as ms, max(val) as mx from inputTbl3 PREHOOK: type: QUERY +PREHOOK: Input: default@inputtbl1_n6 +PREHOOK: Input: default@inputtbl2 +PREHOOK: Input: default@inputtbl3 +#### A masked pattern was here #### POSTHOOK: query: explain SELECT count(1) as rowcnt, min(val) as ms, max(val) as mx from inputTbl1_n6 UNION ALL @@ -134,6 +138,10 @@ POSTHOOK: query: explain UNION ALL SELECT count(1) as rowcnt, min(val) as ms, max(val) as mx from inputTbl3 POSTHOOK: type: QUERY +POSTHOOK: Input: default@inputtbl1_n6 +POSTHOOK: Input: default@inputtbl2 +POSTHOOK: Input: default@inputtbl3 +#### A masked pattern was here #### STAGE DEPENDENCIES: Stage-2 is a root stage Stage-1 depends on stages: Stage-2 @@ -300,6 +308,10 @@ PREHOOK: query: explain UNION ALL SELECT count(1) as rowcnt, min(val) as ms, max(val) as mx from inputTbl3 PREHOOK: type: QUERY +PREHOOK: Input: default@inputtbl1_n6 +PREHOOK: Input: default@inputtbl2 +PREHOOK: Input: default@inputtbl3 +#### A masked pattern was here #### POSTHOOK: query: explain SELECT count(1) as rowcnt, min(val) as ms, max(val) as mx from inputTbl1_n6 UNION ALL @@ -307,6 +319,10 @@ POSTHOOK: query: explain UNION ALL SELECT count(1) as rowcnt, min(val) as ms, max(val) as mx from inputTbl3 POSTHOOK: type: QUERY +POSTHOOK: Input: default@inputtbl1_n6 +POSTHOOK: Input: default@inputtbl2 +POSTHOOK: Input: default@inputtbl3 +#### A masked pattern was here #### STAGE DEPENDENCIES: Stage-0 is a root stage @@ -347,6 +363,10 @@ PREHOOK: query: explain UNION ALL SELECT key, count(1) as rowcnt, min(val) as ms, max(val) as mx from inputTbl3 group by key PREHOOK: type: QUERY +PREHOOK: Input: default@inputtbl1_n6 +PREHOOK: Input: default@inputtbl2 +PREHOOK: Input: default@inputtbl3 +#### A masked pattern was here #### POSTHOOK: query: explain SELECT key, count(1) as rowcnt, min(val) as ms, max(val) as mx from inputTbl1_n6 group by key UNION ALL @@ -354,6 +374,10 @@ POSTHOOK: query: explain UNION ALL SELECT key, count(1) as rowcnt, min(val) as ms, max(val) as mx from inputTbl3 group by key POSTHOOK: type: QUERY +POSTHOOK: Input: default@inputtbl1_n6 +POSTHOOK: Input: default@inputtbl2 +POSTHOOK: Input: default@inputtbl3 +#### A masked pattern was here #### STAGE DEPENDENCIES: Stage-1 is a root stage Stage-0 depends on stages: Stage-1 @@ -522,6 +546,10 @@ PREHOOK: query: explain UNION ALL SELECT count(1) as rowcnt, min(val) as ms, max(val) as mx from inputTbl3 PREHOOK: type: QUERY +PREHOOK: Input: default@inputtbl1_n6 +PREHOOK: Input: default@inputtbl2 +PREHOOK: Input: default@inputtbl3 +#### A masked pattern was here #### POSTHOOK: query: explain SELECT count(1) as rowcnt, min(val) as ms, max(val) as mx from inputTbl1_n6 UNION ALL @@ -529,6 +557,10 @@ POSTHOOK: query: explain UNION ALL SELECT count(1) as rowcnt, min(val) as ms, max(val) as mx from inputTbl3 POSTHOOK: type: QUERY +POSTHOOK: Input: default@inputtbl1_n6 +POSTHOOK: Input: default@inputtbl2 +POSTHOOK: Input: default@inputtbl3 +#### A masked pattern was here #### STAGE DEPENDENCIES: Stage-1 is a root stage Stage-0 depends on stages: Stage-1 @@ -685,6 +717,10 @@ PREHOOK: query: explain UNION ALL SELECT count(1) as rowcnt, min(val) as ms, max(val) as mx from inputTbl3 PREHOOK: type: QUERY +PREHOOK: Input: default@inputtbl1_n6 +PREHOOK: Input: default@inputtbl2 +PREHOOK: Input: default@inputtbl3 +#### A masked pattern was here #### POSTHOOK: query: explain SELECT count(1) as rowcnt, min(val) as ms, max(val) as mx from inputTbl1_n6 UNION ALL @@ -692,6 +728,10 @@ POSTHOOK: query: explain UNION ALL SELECT count(1) as rowcnt, min(val) as ms, max(val) as mx from inputTbl3 POSTHOOK: type: QUERY +POSTHOOK: Input: default@inputtbl1_n6 +POSTHOOK: Input: default@inputtbl2 +POSTHOOK: Input: default@inputtbl3 +#### A masked pattern was here #### STAGE DEPENDENCIES: Stage-1 is a root stage Stage-0 depends on stages: Stage-1 http://git-wip-us.apache.org/repos/asf/hive/blob/b356aae0/ql/src/test/results/clientpositive/llap/union_top_level.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/llap/union_top_level.q.out b/ql/src/test/results/clientpositive/llap/union_top_level.q.out index 0085342..aaec45c 100644 --- a/ql/src/test/results/clientpositive/llap/union_top_level.q.out +++ b/ql/src/test/results/clientpositive/llap/union_top_level.q.out @@ -5,6 +5,8 @@ select * from (select key, 1 as value from src where key % 3 == 1 limit 3)b union all select * from (select key, 2 as value from src where key % 3 == 2 limit 3)c PREHOOK: type: QUERY +PREHOOK: Input: default@src +#### A masked pattern was here #### POSTHOOK: query: explain select * from (select key, 0 as value from src where key % 3 == 0 limit 3)a union all @@ -12,6 +14,8 @@ select * from (select key, 1 as value from src where key % 3 == 1 limit 3)b union all select * from (select key, 2 as value from src where key % 3 == 2 limit 3)c POSTHOOK: type: QUERY +POSTHOOK: Input: default@src +#### A masked pattern was here #### STAGE DEPENDENCIES: Stage-1 is a root stage Stage-0 depends on stages: Stage-1 @@ -194,11 +198,15 @@ select * from (select s1.key as k, s2.value as v from src s1 join src s2 on (s1. union all select * from (select s1.key as k, s2.value as v from src s1 join src s2 on (s1.key = s2.key) order by k limit 10)b PREHOOK: type: QUERY +PREHOOK: Input: default@src +#### A masked pattern was here #### POSTHOOK: query: explain select * from (select s1.key as k, s2.value as v from src s1 join src s2 on (s1.key = s2.key) order by k limit 10)a union all select * from (select s1.key as k, s2.value as v from src s1 join src s2 on (s1.key = s2.key) order by k limit 10)b POSTHOOK: type: QUERY +POSTHOOK: Input: default@src +#### A masked pattern was here #### STAGE DEPENDENCIES: Stage-1 is a root stage Stage-0 depends on stages: Stage-1 @@ -389,6 +397,9 @@ select * from (select key, 1 as value from src where key % 3 == 1 limit 3)b union all select * from (select key, 2 as value from src where key % 3 == 2 limit 3)c PREHOOK: type: CREATETABLE_AS_SELECT +PREHOOK: Input: default@src +PREHOOK: Output: database:default +PREHOOK: Output: default@union_top POSTHOOK: query: explain create table union_top as select * from (select key, 0 as value from src where key % 3 == 0 limit 3)a @@ -397,6 +408,9 @@ select * from (select key, 1 as value from src where key % 3 == 1 limit 3)b union all select * from (select key, 2 as value from src where key % 3 == 2 limit 3)c POSTHOOK: type: CREATETABLE_AS_SELECT +POSTHOOK: Input: default@src +POSTHOOK: Output: database:default +POSTHOOK: Output: default@union_top STAGE DEPENDENCIES: Stage-1 is a root stage Stage-2 depends on stages: Stage-1 @@ -624,6 +638,8 @@ select * from (select key, 1 as value from src where key % 3 == 1 limit 3)b union all select * from (select key, 2 as value from src where key % 3 == 2 limit 3)c PREHOOK: type: QUERY +PREHOOK: Input: default@src +PREHOOK: Output: default@union_top POSTHOOK: query: explain insert into table union_top select * from (select key, 0 as value from src where key % 3 == 0 limit 3)a @@ -632,6 +648,8 @@ select * from (select key, 1 as value from src where key % 3 == 1 limit 3)b union all select * from (select key, 2 as value from src where key % 3 == 2 limit 3)c POSTHOOK: type: QUERY +POSTHOOK: Input: default@src +POSTHOOK: Output: default@union_top STAGE DEPENDENCIES: Stage-1 is a root stage Stage-2 depends on stages: Stage-1 @@ -901,6 +919,8 @@ select * from (select key, 1 as value from src where key % 3 == 1 limit 3)b union all select * from (select key, 2 as value from src where key % 3 == 2 limit 3)c PREHOOK: type: QUERY +PREHOOK: Input: default@src +PREHOOK: Output: default@union_top POSTHOOK: query: explain insert overwrite table union_top select * from (select key, 0 as value from src where key % 3 == 0 limit 3)a @@ -909,6 +929,8 @@ select * from (select key, 1 as value from src where key % 3 == 1 limit 3)b union all select * from (select key, 2 as value from src where key % 3 == 2 limit 3)c POSTHOOK: type: QUERY +POSTHOOK: Input: default@src +POSTHOOK: Output: default@union_top STAGE DEPENDENCIES: Stage-1 is a root stage Stage-2 depends on stages: Stage-1 @@ -1178,6 +1200,9 @@ select * from (select key, 1 as value from src where key % 3 == 1 limit 3)b union all select * from (select key, 2 as value from src where key % 3 == 2 limit 3)c PREHOOK: type: CREATEVIEW +PREHOOK: Input: default@src +PREHOOK: Output: database:default +PREHOOK: Output: default@union_top_view POSTHOOK: query: explain create view union_top_view as select * from (select key, 0 as value from src where key % 3 == 0 limit 3)a @@ -1186,6 +1211,9 @@ select * from (select key, 1 as value from src where key % 3 == 1 limit 3)b union all select * from (select key, 2 as value from src where key % 3 == 2 limit 3)c POSTHOOK: type: CREATEVIEW +POSTHOOK: Input: default@src +POSTHOOK: Output: database:default +POSTHOOK: Output: default@union_top_view STAGE DEPENDENCIES: Stage-1 is a root stage http://git-wip-us.apache.org/repos/asf/hive/blob/b356aae0/ql/src/test/results/clientpositive/llap/vector_adaptor_usage_mode.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/llap/vector_adaptor_usage_mode.q.out b/ql/src/test/results/clientpositive/llap/vector_adaptor_usage_mode.q.out index fba880b..d0f17e5 100644 --- a/ql/src/test/results/clientpositive/llap/vector_adaptor_usage_mode.q.out +++ b/ql/src/test/results/clientpositive/llap/vector_adaptor_usage_mode.q.out @@ -135,6 +135,8 @@ select (c2 regexp 'val') = (c4 regexp 'val') from varchar_udf_1_n0 PREHOOK: type: QUERY +PREHOOK: Input: default@varchar_udf_1_n0 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select c2 regexp 'val', @@ -142,6 +144,8 @@ select (c2 regexp 'val') = (c4 regexp 'val') from varchar_udf_1_n0 POSTHOOK: type: QUERY +POSTHOOK: Input: default@varchar_udf_1_n0 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -211,6 +215,8 @@ select regexp_extract(c2, 'val_([0-9]+)', 1) = regexp_extract(c4, 'val_([0-9]+)', 1) from varchar_udf_1_n0 PREHOOK: type: QUERY +PREHOOK: Input: default@varchar_udf_1_n0 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select regexp_extract(c2, 'val_([0-9]+)', 1), @@ -218,6 +224,8 @@ select regexp_extract(c2, 'val_([0-9]+)', 1) = regexp_extract(c4, 'val_([0-9]+)', 1) from varchar_udf_1_n0 POSTHOOK: type: QUERY +POSTHOOK: Input: default@varchar_udf_1_n0 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -287,6 +295,8 @@ select regexp_replace(c2, 'val', 'replaced') = regexp_replace(c4, 'val', 'replaced') from varchar_udf_1_n0 PREHOOK: type: QUERY +PREHOOK: Input: default@varchar_udf_1_n0 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select regexp_replace(c2, 'val', 'replaced'), @@ -294,6 +304,8 @@ select regexp_replace(c2, 'val', 'replaced') = regexp_replace(c4, 'val', 'replaced') from varchar_udf_1_n0 POSTHOOK: type: QUERY +POSTHOOK: Input: default@varchar_udf_1_n0 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -363,6 +375,8 @@ select (c2 regexp 'val') = (c4 regexp 'val') from varchar_udf_1_n0 PREHOOK: type: QUERY +PREHOOK: Input: default@varchar_udf_1_n0 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select c2 regexp 'val', @@ -370,6 +384,8 @@ select (c2 regexp 'val') = (c4 regexp 'val') from varchar_udf_1_n0 POSTHOOK: type: QUERY +POSTHOOK: Input: default@varchar_udf_1_n0 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -439,6 +455,8 @@ select regexp_extract(c2, 'val_([0-9]+)', 1) = regexp_extract(c4, 'val_([0-9]+)', 1) from varchar_udf_1_n0 PREHOOK: type: QUERY +PREHOOK: Input: default@varchar_udf_1_n0 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select regexp_extract(c2, 'val_([0-9]+)', 1), @@ -446,6 +464,8 @@ select regexp_extract(c2, 'val_([0-9]+)', 1) = regexp_extract(c4, 'val_([0-9]+)', 1) from varchar_udf_1_n0 POSTHOOK: type: QUERY +POSTHOOK: Input: default@varchar_udf_1_n0 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -528,6 +548,8 @@ select regexp_replace(c2, 'val', 'replaced') = regexp_replace(c4, 'val', 'replaced') from varchar_udf_1_n0 PREHOOK: type: QUERY +PREHOOK: Input: default@varchar_udf_1_n0 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select regexp_replace(c2, 'val', 'replaced'), @@ -535,6 +557,8 @@ select regexp_replace(c2, 'val', 'replaced') = regexp_replace(c4, 'val', 'replaced') from varchar_udf_1_n0 POSTHOOK: type: QUERY +POSTHOOK: Input: default@varchar_udf_1_n0 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -612,8 +636,12 @@ NULL NULL NULL replaced_238 replaced_238 true PREHOOK: query: EXPLAIN VECTORIZATION EXPRESSION SELECT POWER(key, 2) FROM DECIMAL_UDF_n1 PREHOOK: type: QUERY +PREHOOK: Input: default@decimal_udf_n1 +#### A masked pattern was here #### POSTHOOK: query: EXPLAIN VECTORIZATION EXPRESSION SELECT POWER(key, 2) FROM DECIMAL_UDF_n1 POSTHOOK: type: QUERY +POSTHOOK: Input: default@decimal_udf_n1 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -712,6 +740,8 @@ SELECT log10(key), sqrt(key) FROM DECIMAL_UDF_n1 WHERE key = 10 PREHOOK: type: QUERY +PREHOOK: Input: default@decimal_udf_n1 +#### A masked pattern was here #### POSTHOOK: query: EXPLAIN VECTORIZATION EXPRESSION SELECT exp(key), ln(key), @@ -719,6 +749,8 @@ SELECT log10(key), sqrt(key) FROM DECIMAL_UDF_n1 WHERE key = 10 POSTHOOK: type: QUERY +POSTHOOK: Input: default@decimal_udf_n1 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -785,8 +817,12 @@ POSTHOOK: Input: default@decimal_udf_n1 22026.465794806718 2.302585092994046 2.302585092994046 1.0 1.0 1.0 1.0 3.1622776601683795 PREHOOK: query: EXPLAIN VECTORIZATION EXPRESSION SELECT POWER(key, 2) FROM DECIMAL_UDF_n1 PREHOOK: type: QUERY +PREHOOK: Input: default@decimal_udf_n1 +#### A masked pattern was here #### POSTHOOK: query: EXPLAIN VECTORIZATION EXPRESSION SELECT POWER(key, 2) FROM DECIMAL_UDF_n1 POSTHOOK: type: QUERY +POSTHOOK: Input: default@decimal_udf_n1 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -885,6 +921,8 @@ SELECT log10(key), sqrt(key) FROM DECIMAL_UDF_n1 WHERE key = 10 PREHOOK: type: QUERY +PREHOOK: Input: default@decimal_udf_n1 +#### A masked pattern was here #### POSTHOOK: query: EXPLAIN VECTORIZATION EXPRESSION SELECT exp(key), ln(key), @@ -892,6 +930,8 @@ SELECT log10(key), sqrt(key) FROM DECIMAL_UDF_n1 WHERE key = 10 POSTHOOK: type: QUERY +POSTHOOK: Input: default@decimal_udf_n1 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -959,9 +999,13 @@ POSTHOOK: Input: default@decimal_udf_n1 PREHOOK: query: explain vectorization expression SELECT key, COUNT(CASE WHEN bool THEN 1 WHEN NOT bool THEN 0 ELSE NULL END) AS cnt_bool0_ok FROM count_case_groupby GROUP BY key PREHOOK: type: QUERY +PREHOOK: Input: default@count_case_groupby +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression SELECT key, COUNT(CASE WHEN bool THEN 1 WHEN NOT bool THEN 0 ELSE NULL END) AS cnt_bool0_ok FROM count_case_groupby GROUP BY key POSTHOOK: type: QUERY +POSTHOOK: Input: default@count_case_groupby +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -1086,9 +1130,13 @@ key5 0 PREHOOK: query: explain vectorization expression SELECT key, COUNT(CASE WHEN bool THEN 1 WHEN NOT bool THEN 0 ELSE NULL END) AS cnt_bool0_ok FROM count_case_groupby GROUP BY key PREHOOK: type: QUERY +PREHOOK: Input: default@count_case_groupby +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression SELECT key, COUNT(CASE WHEN bool THEN 1 WHEN NOT bool THEN 0 ELSE NULL END) AS cnt_bool0_ok FROM count_case_groupby GROUP BY key POSTHOOK: type: QUERY +POSTHOOK: Input: default@count_case_groupby +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] http://git-wip-us.apache.org/repos/asf/hive/blob/b356aae0/ql/src/test/results/clientpositive/llap/vector_aggregate_9.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/llap/vector_aggregate_9.q.out b/ql/src/test/results/clientpositive/llap/vector_aggregate_9.q.out index b1fa6a7..14f061b 100644 --- a/ql/src/test/results/clientpositive/llap/vector_aggregate_9.q.out +++ b/ql/src/test/results/clientpositive/llap/vector_aggregate_9.q.out @@ -104,9 +104,13 @@ POSTHOOK: Lineage: vectortab2korc_n4.ts2 SIMPLE [(vectortab2k_n4)vectortab2k_n4. PREHOOK: query: explain vectorization detail select min(dc), max(dc), sum(dc), avg(dc) from vectortab2korc_n4 PREHOOK: type: QUERY +PREHOOK: Input: default@vectortab2korc_n4 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization detail select min(dc), max(dc), sum(dc), avg(dc) from vectortab2korc_n4 POSTHOOK: type: QUERY +POSTHOOK: Input: default@vectortab2korc_n4 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -244,9 +248,13 @@ POSTHOOK: Input: default@vectortab2korc_n4 PREHOOK: query: explain vectorization detail select min(d), max(d), sum(d), avg(d) from vectortab2korc_n4 PREHOOK: type: QUERY +PREHOOK: Input: default@vectortab2korc_n4 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization detail select min(d), max(d), sum(d), avg(d) from vectortab2korc_n4 POSTHOOK: type: QUERY +POSTHOOK: Input: default@vectortab2korc_n4 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -384,9 +392,13 @@ POSTHOOK: Input: default@vectortab2korc_n4 PREHOOK: query: explain vectorization detail select min(ts), max(ts), sum(ts), avg(ts) from vectortab2korc_n4 PREHOOK: type: QUERY +PREHOOK: Input: default@vectortab2korc_n4 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization detail select min(ts), max(ts), sum(ts), avg(ts) from vectortab2korc_n4 POSTHOOK: type: QUERY +POSTHOOK: Input: default@vectortab2korc_n4 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] http://git-wip-us.apache.org/repos/asf/hive/blob/b356aae0/ql/src/test/results/clientpositive/llap/vector_aggregate_without_gby.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/llap/vector_aggregate_without_gby.q.out b/ql/src/test/results/clientpositive/llap/vector_aggregate_without_gby.q.out index 5c35139..decccdc 100644 --- a/ql/src/test/results/clientpositive/llap/vector_aggregate_without_gby.q.out +++ b/ql/src/test/results/clientpositive/llap/vector_aggregate_without_gby.q.out @@ -36,9 +36,13 @@ POSTHOOK: Lineage: testvec.id SCRIPT [] PREHOOK: query: explain vectorization detail select max(dt), max(greg_dt) from testvec where id=5 PREHOOK: type: QUERY +PREHOOK: Input: default@testvec +#### A masked pattern was here #### POSTHOOK: query: explain vectorization detail select max(dt), max(greg_dt) from testvec where id=5 POSTHOOK: type: QUERY +POSTHOOK: Input: default@testvec +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] http://git-wip-us.apache.org/repos/asf/hive/blob/b356aae0/ql/src/test/results/clientpositive/llap/vector_annotate_stats_select.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/llap/vector_annotate_stats_select.q.out b/ql/src/test/results/clientpositive/llap/vector_annotate_stats_select.q.out index cb463a1..ed85f89 100644 --- a/ql/src/test/results/clientpositive/llap/vector_annotate_stats_select.q.out +++ b/ql/src/test/results/clientpositive/llap/vector_annotate_stats_select.q.out @@ -91,8 +91,12 @@ POSTHOOK: Lineage: alltypes_orc_n4.ts1 SIMPLE [(alltypes_n4)alltypes_n4.FieldSch POSTHOOK: Lineage: alltypes_orc_n4.vc1 SIMPLE [(alltypes_n4)alltypes_n4.FieldSchema(name:vc1, type:varchar(5), comment:null), ] PREHOOK: query: explain select * from alltypes_orc_n4 PREHOOK: type: QUERY +PREHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### POSTHOOK: query: explain select * from alltypes_orc_n4 POSTHOOK: type: QUERY +POSTHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### STAGE DEPENDENCIES: Stage-1 is a root stage Stage-0 depends on stages: Stage-1 @@ -139,8 +143,12 @@ POSTHOOK: Output: default@alltypes_orc_n4 #### A masked pattern was here #### PREHOOK: query: explain select * from alltypes_orc_n4 PREHOOK: type: QUERY +PREHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### POSTHOOK: query: explain select * from alltypes_orc_n4 POSTHOOK: type: QUERY +POSTHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### STAGE DEPENDENCIES: Stage-1 is a root stage Stage-0 depends on stages: Stage-1 @@ -177,8 +185,12 @@ STAGE PLANS: PREHOOK: query: explain select bo1 from alltypes_orc_n4 PREHOOK: type: QUERY +PREHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### POSTHOOK: query: explain select bo1 from alltypes_orc_n4 POSTHOOK: type: QUERY +POSTHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### STAGE DEPENDENCIES: Stage-1 is a root stage Stage-0 depends on stages: Stage-1 @@ -215,8 +227,12 @@ STAGE PLANS: PREHOOK: query: explain select i1 as int1 from alltypes_orc_n4 PREHOOK: type: QUERY +PREHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### POSTHOOK: query: explain select i1 as int1 from alltypes_orc_n4 POSTHOOK: type: QUERY +POSTHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### STAGE DEPENDENCIES: Stage-1 is a root stage Stage-0 depends on stages: Stage-1 @@ -253,8 +269,12 @@ STAGE PLANS: PREHOOK: query: explain select s1 from alltypes_orc_n4 PREHOOK: type: QUERY +PREHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### POSTHOOK: query: explain select s1 from alltypes_orc_n4 POSTHOOK: type: QUERY +POSTHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### STAGE DEPENDENCIES: Stage-1 is a root stage Stage-0 depends on stages: Stage-1 @@ -291,8 +311,12 @@ STAGE PLANS: PREHOOK: query: explain select m1 from alltypes_orc_n4 PREHOOK: type: QUERY +PREHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### POSTHOOK: query: explain select m1 from alltypes_orc_n4 POSTHOOK: type: QUERY +POSTHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### STAGE DEPENDENCIES: Stage-1 is a root stage Stage-0 depends on stages: Stage-1 @@ -329,8 +353,12 @@ STAGE PLANS: PREHOOK: query: explain select bo1, ti1, si1, i1, bi1, f1, d1,s1 from alltypes_orc_n4 PREHOOK: type: QUERY +PREHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### POSTHOOK: query: explain select bo1, ti1, si1, i1, bi1, f1, d1,s1 from alltypes_orc_n4 POSTHOOK: type: QUERY +POSTHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### STAGE DEPENDENCIES: Stage-1 is a root stage Stage-0 depends on stages: Stage-1 @@ -367,8 +395,12 @@ STAGE PLANS: PREHOOK: query: explain vectorization expression select null from alltypes_orc_n4 PREHOOK: type: QUERY +PREHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select null from alltypes_orc_n4 POSTHOOK: type: QUERY +POSTHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -428,8 +460,12 @@ STAGE PLANS: PREHOOK: query: explain vectorization expression select 11 from alltypes_orc_n4 PREHOOK: type: QUERY +PREHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select 11 from alltypes_orc_n4 POSTHOOK: type: QUERY +POSTHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -489,8 +525,12 @@ STAGE PLANS: PREHOOK: query: explain vectorization expression select 11L from alltypes_orc_n4 PREHOOK: type: QUERY +PREHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select 11L from alltypes_orc_n4 POSTHOOK: type: QUERY +POSTHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -550,8 +590,12 @@ STAGE PLANS: PREHOOK: query: explain vectorization expression select 11.0 from alltypes_orc_n4 PREHOOK: type: QUERY +PREHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select 11.0 from alltypes_orc_n4 POSTHOOK: type: QUERY +POSTHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -611,8 +655,12 @@ STAGE PLANS: PREHOOK: query: explain vectorization expression select "hello" from alltypes_orc_n4 PREHOOK: type: QUERY +PREHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select "hello" from alltypes_orc_n4 POSTHOOK: type: QUERY +POSTHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -672,8 +720,12 @@ STAGE PLANS: PREHOOK: query: explain vectorization expression select cast("hello" as char(5)) from alltypes_orc_n4 PREHOOK: type: QUERY +PREHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select cast("hello" as char(5)) from alltypes_orc_n4 POSTHOOK: type: QUERY +POSTHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -733,8 +785,12 @@ STAGE PLANS: PREHOOK: query: explain vectorization expression select cast("hello" as varchar(5)) from alltypes_orc_n4 PREHOOK: type: QUERY +PREHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select cast("hello" as varchar(5)) from alltypes_orc_n4 POSTHOOK: type: QUERY +POSTHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -794,8 +850,12 @@ STAGE PLANS: PREHOOK: query: explain vectorization expression select unbase64("0xe23") from alltypes_orc_n4 PREHOOK: type: QUERY +PREHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select unbase64("0xe23") from alltypes_orc_n4 POSTHOOK: type: QUERY +POSTHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -842,8 +902,12 @@ STAGE PLANS: PREHOOK: query: explain vectorization expression select cast("1" as TINYINT), cast("20" as SMALLINT) from alltypes_orc_n4 PREHOOK: type: QUERY +PREHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select cast("1" as TINYINT), cast("20" as SMALLINT) from alltypes_orc_n4 POSTHOOK: type: QUERY +POSTHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -903,8 +967,12 @@ STAGE PLANS: PREHOOK: query: explain vectorization expression select cast("1970-12-31 15:59:58.174" as TIMESTAMP) from alltypes_orc_n4 PREHOOK: type: QUERY +PREHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select cast("1970-12-31 15:59:58.174" as TIMESTAMP) from alltypes_orc_n4 POSTHOOK: type: QUERY +POSTHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -964,8 +1032,12 @@ STAGE PLANS: PREHOOK: query: explain vectorization expression select cast("1970-12-31 15:59:58.174" as DATE) from alltypes_orc_n4 PREHOOK: type: QUERY +PREHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select cast("1970-12-31 15:59:58.174" as DATE) from alltypes_orc_n4 POSTHOOK: type: QUERY +POSTHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -1025,8 +1097,12 @@ STAGE PLANS: PREHOOK: query: explain vectorization expression select cast("58.174" as DECIMAL) from alltypes_orc_n4 PREHOOK: type: QUERY +PREHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select cast("58.174" as DECIMAL) from alltypes_orc_n4 POSTHOOK: type: QUERY +POSTHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -1086,8 +1162,12 @@ STAGE PLANS: PREHOOK: query: explain vectorization expression select array(1,2,3) from alltypes_orc_n4 PREHOOK: type: QUERY +PREHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select array(1,2,3) from alltypes_orc_n4 POSTHOOK: type: QUERY +POSTHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -1147,8 +1227,12 @@ STAGE PLANS: PREHOOK: query: explain vectorization expression select str_to_map("a=1 b=2 c=3", " ", "=") from alltypes_orc_n4 PREHOOK: type: QUERY +PREHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select str_to_map("a=1 b=2 c=3", " ", "=") from alltypes_orc_n4 POSTHOOK: type: QUERY +POSTHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -1208,8 +1292,12 @@ STAGE PLANS: PREHOOK: query: explain vectorization expression select NAMED_STRUCT("a", 11, "b", 11) from alltypes_orc_n4 PREHOOK: type: QUERY +PREHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select NAMED_STRUCT("a", 11, "b", 11) from alltypes_orc_n4 POSTHOOK: type: QUERY +POSTHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -1269,8 +1357,12 @@ STAGE PLANS: PREHOOK: query: explain vectorization expression select CREATE_UNION(0, "hello") from alltypes_orc_n4 PREHOOK: type: QUERY +PREHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select CREATE_UNION(0, "hello") from alltypes_orc_n4 POSTHOOK: type: QUERY +POSTHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -1330,8 +1422,12 @@ STAGE PLANS: PREHOOK: query: explain vectorization expression select count(*) from alltypes_orc_n4 PREHOOK: type: QUERY +PREHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select count(*) from alltypes_orc_n4 POSTHOOK: type: QUERY +POSTHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -1348,8 +1444,12 @@ STAGE PLANS: PREHOOK: query: explain vectorization expression select count(1) from alltypes_orc_n4 PREHOOK: type: QUERY +PREHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select count(1) from alltypes_orc_n4 POSTHOOK: type: QUERY +POSTHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -1366,8 +1466,12 @@ STAGE PLANS: PREHOOK: query: explain vectorization expression select *,11 from alltypes_orc_n4 PREHOOK: type: QUERY +PREHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select *,11 from alltypes_orc_n4 POSTHOOK: type: QUERY +POSTHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -1427,8 +1531,12 @@ STAGE PLANS: PREHOOK: query: explain vectorization expression select i1 from (select i1 from alltypes_orc_n4 limit 10) temp PREHOOK: type: QUERY +PREHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select i1 from (select i1 from alltypes_orc_n4 limit 10) temp POSTHOOK: type: QUERY +POSTHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -1493,8 +1601,12 @@ STAGE PLANS: PREHOOK: query: explain vectorization expression select i1 from (select i1,11 from alltypes_orc_n4 limit 10) temp PREHOOK: type: QUERY +PREHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select i1 from (select i1,11 from alltypes_orc_n4 limit 10) temp POSTHOOK: type: QUERY +POSTHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -1559,8 +1671,12 @@ STAGE PLANS: PREHOOK: query: explain vectorization expression select i1,"hello" from (select i1,11 from alltypes_orc_n4 limit 10) temp PREHOOK: type: QUERY +PREHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select i1,"hello" from (select i1,11 from alltypes_orc_n4 limit 10) temp POSTHOOK: type: QUERY +POSTHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -1669,8 +1785,12 @@ STAGE PLANS: PREHOOK: query: explain vectorization expression select x from (select i1,11.0 as x from alltypes_orc_n4 limit 10) temp PREHOOK: type: QUERY +PREHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select x from (select i1,11.0 as x from alltypes_orc_n4 limit 10) temp POSTHOOK: type: QUERY +POSTHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -1768,8 +1888,12 @@ STAGE PLANS: PREHOOK: query: explain vectorization expression select x,"hello" from (select i1 as x, unbase64("0xe23") as ub from alltypes_orc_n4 limit 10) temp PREHOOK: type: QUERY +PREHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select x,"hello" from (select i1 as x, unbase64("0xe23") as ub from alltypes_orc_n4 limit 10) temp POSTHOOK: type: QUERY +POSTHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -1878,8 +2002,12 @@ STAGE PLANS: PREHOOK: query: explain vectorization expression select h, 11.0 from (select hell as h from (select i1, "hello" as hell from alltypes_orc_n4 limit 10) in1 limit 10) in2 PREHOOK: type: QUERY +PREHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select h, 11.0 from (select hell as h from (select i1, "hello" as hell from alltypes_orc_n4 limit 10) in1 limit 10) in2 POSTHOOK: type: QUERY +POSTHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -1977,8 +2105,12 @@ STAGE PLANS: PREHOOK: query: explain vectorization expression select bo1 from alltypes_orc_n4 where bo1 PREHOOK: type: QUERY +PREHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select bo1 from alltypes_orc_n4 where bo1 POSTHOOK: type: QUERY +POSTHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -2044,8 +2176,12 @@ STAGE PLANS: PREHOOK: query: explain vectorization expression select bo1 from alltypes_orc_n4 where !bo1 PREHOOK: type: QUERY +PREHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select bo1 from alltypes_orc_n4 where !bo1 POSTHOOK: type: QUERY +POSTHOOK: Input: default@alltypes_orc_n4 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] http://git-wip-us.apache.org/repos/asf/hive/blob/b356aae0/ql/src/test/results/clientpositive/llap/vector_auto_smb_mapjoin_14.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/llap/vector_auto_smb_mapjoin_14.q.out b/ql/src/test/results/clientpositive/llap/vector_auto_smb_mapjoin_14.q.out index 6238281..04235ad 100644 --- a/ql/src/test/results/clientpositive/llap/vector_auto_smb_mapjoin_14.q.out +++ b/ql/src/test/results/clientpositive/llap/vector_auto_smb_mapjoin_14.q.out @@ -43,11 +43,17 @@ select count(*) from ( select a.key as key, a.value as val1, b.value as val2 from tbl1_n12 a join tbl2_n11 b on a.key = b.key ) subq1 PREHOOK: type: QUERY +PREHOOK: Input: default@tbl1_n12 +PREHOOK: Input: default@tbl2_n11 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select count(*) from ( select a.key as key, a.value as val1, b.value as val2 from tbl1_n12 a join tbl2_n11 b on a.key = b.key ) subq1 POSTHOOK: type: QUERY +POSTHOOK: Input: default@tbl1_n12 +POSTHOOK: Input: default@tbl2_n11 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -167,6 +173,9 @@ select count(*) from group by key ) subq2 PREHOOK: type: QUERY +PREHOOK: Input: default@tbl1_n12 +PREHOOK: Input: default@tbl2_n11 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select count(*) from ( @@ -177,6 +186,9 @@ select count(*) from group by key ) subq2 POSTHOOK: type: QUERY +POSTHOOK: Input: default@tbl1_n12 +POSTHOOK: Input: default@tbl2_n11 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -363,6 +375,9 @@ join ) src2 on src1.key = src2.key PREHOOK: type: QUERY +PREHOOK: Input: default@tbl1_n12 +PREHOOK: Input: default@tbl2_n11 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select src1.key, src1.cnt1, src2.cnt1 from ( @@ -380,6 +395,9 @@ join ) src2 on src1.key = src2.key POSTHOOK: type: QUERY +POSTHOOK: Input: default@tbl1_n12 +POSTHOOK: Input: default@tbl2_n11 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -632,6 +650,9 @@ select count(*) from (select a.key as key, a.value as value from tbl2_n11 a where key < 6) subq2 on subq1.key = subq2.key PREHOOK: type: QUERY +PREHOOK: Input: default@tbl1_n12 +PREHOOK: Input: default@tbl2_n11 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select count(*) from (select a.key as key, a.value as value from tbl1_n12 a where key < 6) subq1 @@ -639,6 +660,9 @@ select count(*) from (select a.key as key, a.value as value from tbl2_n11 a where key < 6) subq2 on subq1.key = subq2.key POSTHOOK: type: QUERY +POSTHOOK: Input: default@tbl1_n12 +POSTHOOK: Input: default@tbl2_n11 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -764,6 +788,9 @@ select count(*) from join tbl2_n11 b on subq2.key = b.key PREHOOK: type: QUERY +PREHOOK: Input: default@tbl1_n12 +PREHOOK: Input: default@tbl2_n11 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select count(*) from ( @@ -776,6 +803,9 @@ select count(*) from join tbl2_n11 b on subq2.key = b.key POSTHOOK: type: QUERY +POSTHOOK: Input: default@tbl1_n12 +POSTHOOK: Input: default@tbl2_n11 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -918,6 +948,8 @@ select count(*) from ) subq4 on subq2.key = subq4.key PREHOOK: type: QUERY +PREHOOK: Input: default@tbl1_n12 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select count(*) from ( @@ -937,6 +969,8 @@ select count(*) from ) subq4 on subq2.key = subq4.key POSTHOOK: type: QUERY +POSTHOOK: Input: default@tbl1_n12 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -1079,6 +1113,9 @@ select count(*) from (select a.key as key, concat(a.value, a.value) as value from tbl2_n11 a where key < 8) subq2 on subq1.key = subq2.key PREHOOK: type: QUERY +PREHOOK: Input: default@tbl1_n12 +PREHOOK: Input: default@tbl2_n11 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select count(*) from (select a.key as key, concat(a.value, a.value) as value from tbl1_n12 a where key < 8) subq1 @@ -1086,6 +1123,9 @@ select count(*) from (select a.key as key, concat(a.value, a.value) as value from tbl2_n11 a where key < 8) subq2 on subq1.key = subq2.key POSTHOOK: type: QUERY +POSTHOOK: Input: default@tbl1_n12 +POSTHOOK: Input: default@tbl2_n11 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -1206,6 +1246,9 @@ select count(*) from (select a.key +1 as key, concat(a.value, a.value) as value from tbl2_n11 a) subq2 on subq1.key = subq2.key PREHOOK: type: QUERY +PREHOOK: Input: default@tbl1_n12 +PREHOOK: Input: default@tbl2_n11 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select count(*) from (select a.key +1 as key, concat(a.value, a.value) as value from tbl1_n12 a) subq1 @@ -1213,6 +1256,9 @@ select count(*) from (select a.key +1 as key, concat(a.value, a.value) as value from tbl2_n11 a) subq2 on subq1.key = subq2.key POSTHOOK: type: QUERY +POSTHOOK: Input: default@tbl1_n12 +POSTHOOK: Input: default@tbl2_n11 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -1397,11 +1443,17 @@ select count(*) from (select a.key as key, a.value as value from tbl1_n12 a where key < 6) subq1 join tbl2_n11 a on subq1.key = a.key PREHOOK: type: QUERY +PREHOOK: Input: default@tbl1_n12 +PREHOOK: Input: default@tbl2_n11 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select count(*) from (select a.key as key, a.value as value from tbl1_n12 a where key < 6) subq1 join tbl2_n11 a on subq1.key = a.key POSTHOOK: type: QUERY +POSTHOOK: Input: default@tbl1_n12 +POSTHOOK: Input: default@tbl2_n11 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -1521,6 +1573,9 @@ select count(*) from (select a.key as key, a.value as value from tbl2_n11 a where key < 6) subq3 on (subq1.key = subq3.key) PREHOOK: type: QUERY +PREHOOK: Input: default@tbl1_n12 +PREHOOK: Input: default@tbl2_n11 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select count(*) from (select a.key as key, a.value as value from tbl1_n12 a where key < 6) subq1 @@ -1531,6 +1586,9 @@ select count(*) from (select a.key as key, a.value as value from tbl2_n11 a where key < 6) subq3 on (subq1.key = subq3.key) POSTHOOK: type: QUERY +POSTHOOK: Input: default@tbl1_n12 +POSTHOOK: Input: default@tbl2_n11 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -1676,6 +1734,9 @@ select count(*) from ( join tbl2_n11 b on subq2.key = b.key) a PREHOOK: type: QUERY +PREHOOK: Input: default@tbl1_n12 +PREHOOK: Input: default@tbl2_n11 +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select count(*) from ( select subq2.key as key, subq2.value as value1, b.value as value2 from @@ -1689,6 +1750,9 @@ select count(*) from ( join tbl2_n11 b on subq2.key = b.key) a POSTHOOK: type: QUERY +POSTHOOK: Input: default@tbl1_n12 +POSTHOOK: Input: default@tbl2_n11 +#### A masked pattern was here #### PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -1837,6 +1901,10 @@ from ( insert overwrite table dest1_n157 select key, val1 insert overwrite table dest2_n40 select key, val1, val2 PREHOOK: type: QUERY +PREHOOK: Input: default@tbl1_n12 +PREHOOK: Input: default@tbl2_n11 +PREHOOK: Output: default@dest1_n157 +PREHOOK: Output: default@dest2_n40 POSTHOOK: query: explain vectorization expression from ( select a.key as key, a.value as val1, b.value as val2 from tbl1_n12 a join tbl2_n11 b on a.key = b.key @@ -1844,6 +1912,10 @@ from ( insert overwrite table dest1_n157 select key, val1 insert overwrite table dest2_n40 select key, val1, val2 POSTHOOK: type: QUERY +POSTHOOK: Input: default@tbl1_n12 +POSTHOOK: Input: default@tbl2_n11 +POSTHOOK: Output: default@dest1_n157 +POSTHOOK: Output: default@dest2_n40 PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] @@ -2057,6 +2129,10 @@ from ( insert overwrite table dest1_n157 select key, val1 insert overwrite table dest2_n40 select key, count(*) group by key PREHOOK: type: QUERY +PREHOOK: Input: default@tbl1_n12 +PREHOOK: Input: default@tbl2_n11 +PREHOOK: Output: default@dest1_n157 +PREHOOK: Output: default@dest2_n40 POSTHOOK: query: explain vectorization expression from ( select a.key as key, a.value as val1, b.value as val2 from tbl1_n12 a join tbl2_n11 b on a.key = b.key @@ -2064,6 +2140,10 @@ from ( insert overwrite table dest1_n157 select key, val1 insert overwrite table dest2_n40 select key, count(*) group by key POSTHOOK: type: QUERY +POSTHOOK: Input: default@tbl1_n12 +POSTHOOK: Input: default@tbl2_n11 +POSTHOOK: Output: default@dest1_n157 +POSTHOOK: Output: default@dest2_n40 PLAN VECTORIZATION: enabled: true enabledConditionsMet: [hive.vectorized.execution.enabled IS true] http://git-wip-us.apache.org/repos/asf/hive/blob/b356aae0/ql/src/test/results/clientpositive/llap/vector_between_columns.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/llap/vector_between_columns.q.out b/ql/src/test/results/clientpositive/llap/vector_between_columns.q.out index 1824976..ee30941 100644 --- a/ql/src/test/results/clientpositive/llap/vector_between_columns.q.out +++ b/ql/src/test/results/clientpositive/llap/vector_between_columns.q.out @@ -86,9 +86,15 @@ Warning: Shuffle Join MERGEJOIN[9][tables = [$hdt$_0, $hdt$_1]] in Stage 'Reduce PREHOOK: query: explain vectorization expression select tint.rnum, tsint.rnum, tint.cint, tsint.csint, (case when (tint.cint between tsint.csint and tsint.csint) then "Ok" else "NoOk" end) as between_col from tint , tsint PREHOOK: type: QUERY +PREHOOK: Input: default@tint +PREHOOK: Input: default@tsint +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select tint.rnum, tsint.rnum, tint.cint, tsint.csint, (case when (tint.cint between tsint.csint and tsint.csint) then "Ok" else "NoOk" end) as between_col from tint , tsint POSTHOOK: type: QUERY +POSTHOOK: Input: default@tint +POSTHOOK: Input: default@tsint +#### A masked pattern was here #### Explain PLAN VECTORIZATION: enabled: true @@ -255,9 +261,15 @@ Warning: Shuffle Join MERGEJOIN[10][tables = [$hdt$_0, $hdt$_1]] in Stage 'Reduc PREHOOK: query: explain vectorization expression select tint.rnum, tsint.rnum, tint.cint, tsint.csint from tint , tsint where tint.cint between tsint.csint and tsint.csint PREHOOK: type: QUERY +PREHOOK: Input: default@tint +PREHOOK: Input: default@tsint +#### A masked pattern was here #### POSTHOOK: query: explain vectorization expression select tint.rnum, tsint.rnum, tint.cint, tsint.csint from tint , tsint where tint.cint between tsint.csint and tsint.csint POSTHOOK: type: QUERY +POSTHOOK: Input: default@tint +POSTHOOK: Input: default@tsint +#### A masked pattern was here #### Explain PLAN VECTORIZATION: enabled: true
