http://git-wip-us.apache.org/repos/asf/hive/blob/bbfc4d9d/ql/src/test/results/clientpositive/llap/cte_2.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/llap/cte_2.q.out b/ql/src/test/results/clientpositive/llap/cte_2.q.out index 017bded..e42d538 100644 --- a/ql/src/test/results/clientpositive/llap/cte_2.q.out +++ b/ql/src/test/results/clientpositive/llap/cte_2.q.out @@ -188,3 +188,31 @@ POSTHOOK: query: drop view v1 POSTHOOK: type: DROPVIEW POSTHOOK: Input: default@v1 POSTHOOK: Output: default@v1 +PREHOOK: query: drop view if exists view_3 +PREHOOK: type: DROPVIEW +POSTHOOK: query: drop view if exists view_3 +POSTHOOK: type: DROPVIEW +PREHOOK: query: create view view_3 as select cstring2, AVG(cint) from alltypesorc group by cstring2 limit 10 +PREHOOK: type: CREATEVIEW +PREHOOK: Input: default@alltypesorc +PREHOOK: Output: database:default +PREHOOK: Output: default@view_3 +POSTHOOK: query: create view view_3 as select cstring2, AVG(cint) from alltypesorc group by cstring2 limit 10 +POSTHOOK: type: CREATEVIEW +POSTHOOK: Input: default@alltypesorc +POSTHOOK: Output: database:default +POSTHOOK: Output: default@view_3 +PREHOOK: query: drop view if exists view_4 +PREHOOK: type: DROPVIEW +POSTHOOK: query: drop view if exists view_4 +POSTHOOK: type: DROPVIEW +PREHOOK: query: create view view_4 as select s.cstring1, v.ctimestamp1 from alltypesorc s join alltypesorc v on (s.cstring2= v.cstring1) +PREHOOK: type: CREATEVIEW +PREHOOK: Input: default@alltypesorc +PREHOOK: Output: database:default +PREHOOK: Output: default@view_4 +POSTHOOK: query: create view view_4 as select s.cstring1, v.ctimestamp1 from alltypesorc s join alltypesorc v on (s.cstring2= v.cstring1) +POSTHOOK: type: CREATEVIEW +POSTHOOK: Input: default@alltypesorc +POSTHOOK: Output: database:default +POSTHOOK: Output: default@view_4
http://git-wip-us.apache.org/repos/asf/hive/blob/bbfc4d9d/ql/src/test/results/clientpositive/llap/join_acid_non_acid.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/llap/join_acid_non_acid.q.out b/ql/src/test/results/clientpositive/llap/join_acid_non_acid.q.out index 4905351..efe7699 100644 --- a/ql/src/test/results/clientpositive/llap/join_acid_non_acid.q.out +++ b/ql/src/test/results/clientpositive/llap/join_acid_non_acid.q.out @@ -56,3 +56,19 @@ POSTHOOK: Input: default@orc_table POSTHOOK: Input: default@orc_update_table #### A masked pattern was here #### 1 x 1 a I +PREHOOK: query: select t1.k1, t1.f1 from orc_table t1 + union all +select t2.k1, t2.f1 from orc_update_table t2 +PREHOOK: type: QUERY +PREHOOK: Input: default@orc_table +PREHOOK: Input: default@orc_update_table +#### A masked pattern was here #### +POSTHOOK: query: select t1.k1, t1.f1 from orc_table t1 + union all +select t2.k1, t2.f1 from orc_update_table t2 +POSTHOOK: type: QUERY +POSTHOOK: Input: default@orc_table +POSTHOOK: Input: default@orc_update_table +#### A masked pattern was here #### +1 x +1 a http://git-wip-us.apache.org/repos/asf/hive/blob/bbfc4d9d/ql/src/test/results/clientpositive/llap/lvj_mapjoin.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/llap/lvj_mapjoin.q.out b/ql/src/test/results/clientpositive/llap/lvj_mapjoin.q.out index dd4d024..366eda0 100644 --- a/ql/src/test/results/clientpositive/llap/lvj_mapjoin.q.out +++ b/ql/src/test/results/clientpositive/llap/lvj_mapjoin.q.out @@ -295,3 +295,50 @@ POSTHOOK: Input: default@expod2 2 a222 b2 2 a222 b22 2 a222 b222 +PREHOOK: query: create temporary table tmp_lateral_view( + arst array<struct<age:int,name:string>> + ) stored as orc +PREHOOK: type: CREATETABLE +PREHOOK: Output: database:default +PREHOOK: Output: default@tmp_lateral_view +POSTHOOK: query: create temporary table tmp_lateral_view( + arst array<struct<age:int,name:string>> + ) stored as orc +POSTHOOK: type: CREATETABLE +POSTHOOK: Output: database:default +POSTHOOK: Output: default@tmp_lateral_view +PREHOOK: query: insert into table tmp_lateral_view + select array(named_struct('age',cint,'name',cstring1)) + from alltypesorc limit 10 +PREHOOK: type: QUERY +PREHOOK: Input: default@alltypesorc +PREHOOK: Output: default@tmp_lateral_view +POSTHOOK: query: insert into table tmp_lateral_view + select array(named_struct('age',cint,'name',cstring1)) + from alltypesorc limit 10 +POSTHOOK: type: QUERY +POSTHOOK: Input: default@alltypesorc +POSTHOOK: Output: default@tmp_lateral_view +POSTHOOK: Lineage: tmp_lateral_view.arst EXPRESSION [(alltypesorc)alltypesorc.FieldSchema(name:cint, type:int, comment:null), (alltypesorc)alltypesorc.FieldSchema(name:cstring1, type:string, comment:null), ] +PREHOOK: query: select arst.name, arst.age + from tmp_lateral_view + lateral view inline(arst) arst +PREHOOK: type: QUERY +PREHOOK: Input: default@tmp_lateral_view +#### A masked pattern was here #### +POSTHOOK: query: select arst.name, arst.age + from tmp_lateral_view + lateral view inline(arst) arst +POSTHOOK: type: QUERY +POSTHOOK: Input: default@tmp_lateral_view +#### A masked pattern was here #### +cvLH6Eat2yFsyy7p 528534767 +cvLH6Eat2yFsyy7p 528534767 +cvLH6Eat2yFsyy7p 528534767 +cvLH6Eat2yFsyy7p 528534767 +cvLH6Eat2yFsyy7p 528534767 +cvLH6Eat2yFsyy7p 528534767 +cvLH6Eat2yFsyy7p 528534767 +cvLH6Eat2yFsyy7p 528534767 +cvLH6Eat2yFsyy7p 528534767 +cvLH6Eat2yFsyy7p 528534767 http://git-wip-us.apache.org/repos/asf/hive/blob/bbfc4d9d/ql/src/test/results/clientpositive/llap/orc_ppd_basic.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/llap/orc_ppd_basic.q.out b/ql/src/test/results/clientpositive/llap/orc_ppd_basic.q.out index aa37ff3..f50d28b 100644 --- a/ql/src/test/results/clientpositive/llap/orc_ppd_basic.q.out +++ b/ql/src/test/results/clientpositive/llap/orc_ppd_basic.q.out @@ -1354,3 +1354,223 @@ Stage-1 LLAP IO COUNTERS: ROWS_EMITTED: 2100 SELECTED_ROWGROUPS: 3 2 +PREHOOK: query: create temporary table tmp_orcppd + stored as orc + as select ctinyint, csmallint, cint , cbigint, cfloat, cdouble, + cstring1, cstring2, ctimestamp1, ctimestamp2 + from alltypesorc limit 20 +PREHOOK: type: CREATETABLE_AS_SELECT +PREHOOK: Input: default@alltypesorc +PREHOOK: Output: database:default +PREHOOK: Output: default@tmp_orcppd +Stage-1 FILE SYSTEM COUNTERS: + HDFS_BYTES_READ: 0 + HDFS_BYTES_WRITTEN: 1571 + HDFS_READ_OPS: 3 + HDFS_LARGE_READ_OPS: 0 + HDFS_WRITE_OPS: 3 +Stage-1 HIVE COUNTERS: + CREATED_FILES: 1 + DESERIALIZE_ERRORS: 0 + RECORDS_IN_Map_1: 24 + RECORDS_OUT_1_default.tmp_orcppd: 20 + RECORDS_OUT_INTERMEDIATE_Map_1: 20 +Stage-1 LLAP IO COUNTERS: + CACHE_HIT_BYTES: 105700 + CACHE_MISS_BYTES: 0 + METADATA_CACHE_HIT: 2 + NUM_DECODED_BATCHES: 1 + NUM_VECTOR_BATCHES: 5 + ROWS_EMITTED: 5000 + SELECTED_ROWGROUPS: 3 +PREHOOK: query: insert into table tmp_orcppd + values(null, null, null, null, null, + null, null, null, null, null) +PREHOOK: type: QUERY +PREHOOK: Input: default@values__tmp__table__1 +PREHOOK: Output: default@tmp_orcppd +Stage-1 FILE SYSTEM COUNTERS: + HDFS_BYTES_READ: 30 + HDFS_BYTES_WRITTEN: 724 + HDFS_READ_OPS: 4 + HDFS_LARGE_READ_OPS: 0 + HDFS_WRITE_OPS: 3 +Stage-1 HIVE COUNTERS: + CREATED_FILES: 1 + DESERIALIZE_ERRORS: 0 + RECORDS_IN_Map_1: 1 + RECORDS_OUT_1_default.tmp_orcppd: 1 +PREHOOK: query: drop table if exists tbl_orcppd_1_1 +PREHOOK: type: DROPTABLE +PREHOOK: query: create table tbl_orcppd_1_1 as + select count(*) from tmp_orcppd + where ctimestamp1> current_timestamp() and + ctimestamp2 > current_timestamp() and + cstring1 like 'a*' and + cstring2 like 'a*' +PREHOOK: type: CREATETABLE_AS_SELECT +PREHOOK: Input: default@tmp_orcppd +PREHOOK: Output: database:default +PREHOOK: Output: default@tbl_orcppd_1_1 +Stage-1 FILE SYSTEM COUNTERS: + HDFS_BYTES_READ: 0 + HDFS_BYTES_WRITTEN: 80 + HDFS_READ_OPS: 3 + HDFS_LARGE_READ_OPS: 0 + HDFS_WRITE_OPS: 3 +Stage-1 HIVE COUNTERS: + CREATED_FILES: 1 + RECORDS_OUT_1_default.tbl_orcppd_1_1: 1 +PREHOOK: query: drop table if exists tmp_orcppd +PREHOOK: type: DROPTABLE +PREHOOK: Input: default@tmp_orcppd +PREHOOK: Output: default@tmp_orcppd +PREHOOK: query: create temporary table tmp_orcppd + stored as orc + as select ctimestamp1, ctimestamp2 + from alltypesorc limit 10 +PREHOOK: type: CREATETABLE_AS_SELECT +PREHOOK: Input: default@alltypesorc +PREHOOK: Output: database:default +PREHOOK: Output: default@tmp_orcppd +Stage-1 FILE SYSTEM COUNTERS: + HDFS_BYTES_READ: 0 + HDFS_BYTES_WRITTEN: 491 + HDFS_READ_OPS: 3 + HDFS_LARGE_READ_OPS: 0 + HDFS_WRITE_OPS: 3 +Stage-1 HIVE COUNTERS: + CREATED_FILES: 1 + DESERIALIZE_ERRORS: 0 + RECORDS_IN_Map_1: 14 + RECORDS_OUT_1_default.tmp_orcppd: 10 + RECORDS_OUT_INTERMEDIATE_Map_1: 10 +Stage-1 LLAP IO COUNTERS: + CACHE_HIT_BYTES: 30589 + CACHE_MISS_BYTES: 0 + METADATA_CACHE_HIT: 3 + NUM_DECODED_BATCHES: 1 + NUM_VECTOR_BATCHES: 5 + ROWS_EMITTED: 5000 + SELECTED_ROWGROUPS: 3 +PREHOOK: query: insert into table tmp_orcppd + values(null, null) +PREHOOK: type: QUERY +PREHOOK: Input: default@values__tmp__table__2 +PREHOOK: Output: default@tmp_orcppd +Stage-1 FILE SYSTEM COUNTERS: + HDFS_BYTES_READ: 6 + HDFS_BYTES_WRITTEN: 317 + HDFS_READ_OPS: 4 + HDFS_LARGE_READ_OPS: 0 + HDFS_WRITE_OPS: 3 +Stage-1 HIVE COUNTERS: + CREATED_FILES: 1 + DESERIALIZE_ERRORS: 0 + RECORDS_IN_Map_1: 1 + RECORDS_OUT_1_default.tmp_orcppd: 1 +PREHOOK: query: drop table if exists tbl_orcppd_2_1 +PREHOOK: type: DROPTABLE +PREHOOK: query: create table tbl_orcppd_2_1 as + select count(*) from tmp_orcppd + where ctimestamp1 in (cast('2065-08-13 19:03:52' as timestamp), cast('2071-01-16 20:21:17' as timestamp), current_timestamp()) +PREHOOK: type: CREATETABLE_AS_SELECT +PREHOOK: Input: default@tmp_orcppd +PREHOOK: Output: database:default +PREHOOK: Output: default@tbl_orcppd_2_1 +Stage-1 FILE SYSTEM COUNTERS: + HDFS_BYTES_READ: 0 + HDFS_BYTES_WRITTEN: 80 + HDFS_READ_OPS: 3 + HDFS_LARGE_READ_OPS: 0 + HDFS_WRITE_OPS: 3 +Stage-1 HIVE COUNTERS: + CREATED_FILES: 1 + RECORDS_OUT_1_default.tbl_orcppd_2_1: 1 +PREHOOK: query: drop table if exists tmp_orcppd +PREHOOK: type: DROPTABLE +PREHOOK: Input: default@tmp_orcppd +PREHOOK: Output: default@tmp_orcppd +PREHOOK: query: create temporary table tmp_orcppd + stored as orc + as select ts, da + from orc_ppd_staging +PREHOOK: type: CREATETABLE_AS_SELECT +PREHOOK: Input: default@orc_ppd_staging +PREHOOK: Output: database:default +PREHOOK: Output: default@tmp_orcppd +Stage-1 FILE SYSTEM COUNTERS: + HDFS_BYTES_READ: 846 + HDFS_BYTES_WRITTEN: 2979 + HDFS_READ_OPS: 9 + HDFS_LARGE_READ_OPS: 0 + HDFS_WRITE_OPS: 3 +Stage-1 HIVE COUNTERS: + CREATED_FILES: 1 + DESERIALIZE_ERRORS: 0 + RECORDS_IN_Map_1: 2100 + RECORDS_OUT_1_default.tmp_orcppd: 2100 +Stage-1 LLAP IO COUNTERS: + ALLOCATED_BYTES: 786432 + ALLOCATED_USED_BYTES: 38 + CACHE_HIT_BYTES: 2587 + CACHE_MISS_BYTES: 32 + METADATA_CACHE_HIT: 3 + METADATA_CACHE_MISS: 3 + NUM_DECODED_BATCHES: 5 + NUM_VECTOR_BATCHES: 5 + ROWS_EMITTED: 2100 + SELECTED_ROWGROUPS: 5 +PREHOOK: query: insert into table tmp_orcppd + values(null, null) +PREHOOK: type: QUERY +PREHOOK: Input: default@values__tmp__table__3 +PREHOOK: Output: default@tmp_orcppd +Stage-1 FILE SYSTEM COUNTERS: + HDFS_BYTES_READ: 6 + HDFS_BYTES_WRITTEN: 315 + HDFS_READ_OPS: 4 + HDFS_LARGE_READ_OPS: 0 + HDFS_WRITE_OPS: 3 +Stage-1 HIVE COUNTERS: + CREATED_FILES: 1 + DESERIALIZE_ERRORS: 0 + RECORDS_IN_Map_1: 1 + RECORDS_OUT_1_default.tmp_orcppd: 1 +PREHOOK: query: drop table if exists tbl_orcppd_3_1 +PREHOOK: type: DROPTABLE +PREHOOK: query: create table tbl_orcppd_3_1 as + select count(*) from tmp_orcppd + group by ts, da + having ts in (select ctimestamp1 from alltypesorc limit 10) +PREHOOK: type: CREATETABLE_AS_SELECT +PREHOOK: Input: default@alltypesorc +PREHOOK: Input: default@tmp_orcppd +PREHOOK: Output: database:default +PREHOOK: Output: default@tbl_orcppd_3_1 +Stage-1 FILE SYSTEM COUNTERS: + HDFS_BYTES_READ: 5623 + HDFS_BYTES_WRITTEN: 48 + HDFS_READ_OPS: 5 + HDFS_LARGE_READ_OPS: 0 + HDFS_WRITE_OPS: 1 +Stage-1 HIVE COUNTERS: + DESERIALIZE_ERRORS: 0 + RECORDS_IN_Map_1: 2100 + RECORDS_IN_Map_4: 14 + RECORDS_OUT_1_default.tbl_orcppd_3_1: 0 + RECORDS_OUT_INTERMEDIATE_Map_1: 254 + RECORDS_OUT_INTERMEDIATE_Map_4: 10 + RECORDS_OUT_INTERMEDIATE_Reducer_2: 254 + RECORDS_OUT_INTERMEDIATE_Reducer_5: 9 +Stage-1 LLAP IO COUNTERS: + ALLOCATED_BYTES: 786432 + ALLOCATED_USED_BYTES: 6361 + CACHE_HIT_BYTES: 16353 + CACHE_MISS_BYTES: 2590 + METADATA_CACHE_HIT: 3 + METADATA_CACHE_MISS: 2 + NUM_DECODED_BATCHES: 3 + NUM_VECTOR_BATCHES: 13 + ROWS_EMITTED: 12100 + SELECTED_ROWGROUPS: 4
