http://git-wip-us.apache.org/repos/asf/hive/blob/7e64114d/ql/src/test/results/clientpositive/llap/bucket_map_join_tez2.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/llap/bucket_map_join_tez2.q.out b/ql/src/test/results/clientpositive/llap/bucket_map_join_tez2.q.out index b527832..fa90ccd 100644 --- a/ql/src/test/results/clientpositive/llap/bucket_map_join_tez2.q.out +++ b/ql/src/test/results/clientpositive/llap/bucket_map_join_tez2.q.out @@ -1725,25 +1725,31 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@big PREHOOK: query: insert into small values (1),(2),(3),(4),(5),(6) PREHOOK: type: QUERY +PREHOOK: Input: _dummy_database@_dummy_table PREHOOK: Output: default@small POSTHOOK: query: insert into small values (1),(2),(3),(4),(5),(6) POSTHOOK: type: QUERY +POSTHOOK: Input: _dummy_database@_dummy_table POSTHOOK: Output: default@small -POSTHOOK: Lineage: small.i EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] +POSTHOOK: Lineage: small.i SCRIPT [] PREHOOK: query: insert into big partition(k=1) values(1),(3),(5),(7),(9) PREHOOK: type: QUERY +PREHOOK: Input: _dummy_database@_dummy_table PREHOOK: Output: default@big@k=1 POSTHOOK: query: insert into big partition(k=1) values(1),(3),(5),(7),(9) POSTHOOK: type: QUERY +POSTHOOK: Input: _dummy_database@_dummy_table POSTHOOK: Output: default@big@k=1 -POSTHOOK: Lineage: big PARTITION(k=1).i EXPRESSION [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col1, type:string, comment:), ] +POSTHOOK: Lineage: big PARTITION(k=1).i SCRIPT [] PREHOOK: query: insert into big partition(k=2) values(0),(2),(4),(6),(8) PREHOOK: type: QUERY +PREHOOK: Input: _dummy_database@_dummy_table PREHOOK: Output: default@big@k=2 POSTHOOK: query: insert into big partition(k=2) values(0),(2),(4),(6),(8) POSTHOOK: type: QUERY +POSTHOOK: Input: _dummy_database@_dummy_table POSTHOOK: Output: default@big@k=2 -POSTHOOK: Lineage: big PARTITION(k=2).i EXPRESSION [(values__tmp__table__3)values__tmp__table__3.FieldSchema(name:tmp_values_col1, type:string, comment:), ] +POSTHOOK: Lineage: big PARTITION(k=2).i SCRIPT [] PREHOOK: query: explain select small.i, big.i from small,big where small.i=big.i PREHOOK: type: QUERY POSTHOOK: query: explain select small.i, big.i from small,big where small.i=big.i
http://git-wip-us.apache.org/repos/asf/hive/blob/7e64114d/ql/src/test/results/clientpositive/llap/cbo_rp_lineage2.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/llap/cbo_rp_lineage2.q.out b/ql/src/test/results/clientpositive/llap/cbo_rp_lineage2.q.out deleted file mode 100644 index 93bd4ba..0000000 --- a/ql/src/test/results/clientpositive/llap/cbo_rp_lineage2.q.out +++ /dev/null @@ -1,675 +0,0 @@ -PREHOOK: query: drop table if exists src2 -PREHOOK: type: DROPTABLE -PREHOOK: query: create table src2 as select key key2, value value2 from src1 -PREHOOK: type: CREATETABLE_AS_SELECT -PREHOOK: Input: default@src1 -PREHOOK: Output: database:default -PREHOOK: Output: default@src2 -{"version":"1.0","engine":"tez","database":"default","hash":"87921246fb098d44c05e0ccd9ecb0676","queryText":"create table src2 as select key key2, value value2 from src1","edges":[{"sources":[2],"targets":[0],"edgeType":"PROJECTION"},{"sources":[3],"targets":[1],"edgeType":"PROJECTION"}],"vertices":[{"id":0,"vertexType":"COLUMN","vertexId":"default.src2.key2"},{"id":1,"vertexType":"COLUMN","vertexId":"default.src2.value2"},{"id":2,"vertexType":"COLUMN","vertexId":"default.src1.key"},{"id":3,"vertexType":"COLUMN","vertexId":"default.src1.value"}]} -PREHOOK: query: select * from src1 where key is not null and value is not null limit 3 -PREHOOK: type: QUERY -PREHOOK: Input: default@src1 -#### A masked pattern was here #### -{"version":"1.0","engine":"tez","database":"default","hash":"b77bec92ea2b15f580029166380e32df","queryText":"select * from src1 where key is not null and value is not null limit 3","edges":[{"sources":[2],"targets":[0],"edgeType":"PROJECTION"},{"sources":[3],"targets":[1],"edgeType":"PROJECTION"},{"sources":[2,3],"targets":[0,1],"expression":"(src1.key is not null and src1.value is not null)","edgeType":"PREDICATE"}],"vertices":[{"id":0,"vertexType":"COLUMN","vertexId":"src1.key"},{"id":1,"vertexType":"COLUMN","vertexId":"src1.value"},{"id":2,"vertexType":"COLUMN","vertexId":"default.src1.key"},{"id":3,"vertexType":"COLUMN","vertexId":"default.src1.value"}]} -238 val_238 - -311 val_311 -PREHOOK: query: select * from src1 where key > 10 and value > 'val' order by key limit 5 -PREHOOK: type: QUERY -PREHOOK: Input: default@src1 -#### A masked pattern was here #### -{"version":"1.0","engine":"tez","database":"default","hash":"e07e602503383cf2b8477d43c5043f35","queryText":"select * from src1 where key > 10 and value > 'val' order by key limit 5","edges":[{"sources":[2],"targets":[0],"edgeType":"PROJECTION"},{"sources":[3],"targets":[1],"edgeType":"PROJECTION"},{"sources":[2,3],"targets":[0,1],"expression":"((UDFToDouble(src1.key) > 10.0) and (src1.value > 'val'))","edgeType":"PREDICATE"}],"vertices":[{"id":0,"vertexType":"COLUMN","vertexId":"src1.key"},{"id":1,"vertexType":"COLUMN","vertexId":"src1.value"},{"id":2,"vertexType":"COLUMN","vertexId":"default.src1.key"},{"id":3,"vertexType":"COLUMN","vertexId":"default.src1.value"}]} -146 val_146 -150 val_150 -213 val_213 -238 val_238 -255 val_255 -PREHOOK: query: drop table if exists dest1 -PREHOOK: type: DROPTABLE -PREHOOK: query: create table dest1 as select * from src1 -PREHOOK: type: CREATETABLE_AS_SELECT -PREHOOK: Input: default@src1 -PREHOOK: Output: database:default -PREHOOK: Output: default@dest1 -{"version":"1.0","engine":"tez","database":"default","hash":"c8bd31dac3a04a3f46e25c321f0e7ee5","queryText":"create table dest1 as select * from src1","edges":[{"sources":[2],"targets":[0],"edgeType":"PROJECTION"},{"sources":[3],"targets":[1],"edgeType":"PROJECTION"}],"vertices":[{"id":0,"vertexType":"COLUMN","vertexId":"default.dest1.key"},{"id":1,"vertexType":"COLUMN","vertexId":"default.dest1.value"},{"id":2,"vertexType":"COLUMN","vertexId":"default.src1.key"},{"id":3,"vertexType":"COLUMN","vertexId":"default.src1.value"}]} -PREHOOK: query: insert into table dest1 select * from src2 -PREHOOK: type: QUERY -PREHOOK: Input: default@src2 -PREHOOK: Output: default@dest1 -{"version":"1.0","engine":"tez","database":"default","hash":"94331587449f875a25b81ad164091bfa","queryText":"insert into table dest1 select * from src2","edges":[{"sources":[2],"targets":[0],"edgeType":"PROJECTION"},{"sources":[3],"targets":[1],"edgeType":"PROJECTION"},{"sources":[2],"targets":[0],"expression":"compute_stats(default.src2.key2, 'hll')","edgeType":"PROJECTION"},{"sources":[3],"targets":[1],"expression":"compute_stats(default.src2.value2, 'hll')","edgeType":"PROJECTION"}],"vertices":[{"id":0,"vertexType":"COLUMN","vertexId":"default.dest1.key"},{"id":1,"vertexType":"COLUMN","vertexId":"default.dest1.value"},{"id":2,"vertexType":"COLUMN","vertexId":"default.src2.key2"},{"id":3,"vertexType":"COLUMN","vertexId":"default.src2.value2"}]} -PREHOOK: query: select key k, dest1.value from dest1 -PREHOOK: type: QUERY -PREHOOK: Input: default@dest1 -#### A masked pattern was here #### -{"version":"1.0","engine":"tez","database":"default","hash":"51ab34db14fe68ca74dd33da767d3ef7","queryText":"select key k, dest1.value from dest1","edges":[{"sources":[2],"targets":[0],"edgeType":"PROJECTION"},{"sources":[3],"targets":[1],"edgeType":"PROJECTION"}],"vertices":[{"id":0,"vertexType":"COLUMN","vertexId":"k"},{"id":1,"vertexType":"COLUMN","vertexId":"dest1.value"},{"id":2,"vertexType":"COLUMN","vertexId":"default.dest1.key"},{"id":3,"vertexType":"COLUMN","vertexId":"default.dest1.value"}]} -238 val_238 - -311 val_311 - val_27 - val_165 - val_409 -255 val_255 -278 val_278 -98 val_98 - val_484 - val_265 - val_193 -401 val_401 -150 val_150 -273 val_273 -224 -369 -66 val_66 -128 -213 val_213 -146 val_146 -406 val_406 - - - -238 val_238 - -311 val_311 - val_27 - val_165 - val_409 -255 val_255 -278 val_278 -98 val_98 - val_484 - val_265 - val_193 -401 val_401 -150 val_150 -273 val_273 -224 -369 -66 val_66 -128 -213 val_213 -146 val_146 -406 val_406 - - - -PREHOOK: query: select key from src1 union select key2 from src2 order by key -PREHOOK: type: QUERY -PREHOOK: Input: default@src1 -PREHOOK: Input: default@src2 -#### A masked pattern was here #### -{"version":"1.0","engine":"tez","database":"default","hash":"c437b7da00d7f2133c264b86e8e5688b","queryText":"select key from src1 union select key2 from src2 order by key","edges":[{"sources":[1,2],"targets":[0],"expression":"KEY.reducesinkkey0","edgeType":"PROJECTION"}],"vertices":[{"id":0,"vertexType":"COLUMN","vertexId":"key"},{"id":1,"vertexType":"COLUMN","vertexId":"default.src1.key"},{"id":2,"vertexType":"COLUMN","vertexId":"default.src2.key2"}]} - -128 -146 -150 -213 -224 -238 -255 -273 -278 -311 -369 -401 -406 -66 -98 -PREHOOK: query: select key k from src1 union select key2 from src2 order by k -PREHOOK: type: QUERY -PREHOOK: Input: default@src1 -PREHOOK: Input: default@src2 -#### A masked pattern was here #### -{"version":"1.0","engine":"tez","database":"default","hash":"8a689d34ce64f6ede5c3f5665fb5c3e7","queryText":"select key k from src1 union select key2 from src2 order by k","edges":[{"sources":[1,2],"targets":[0],"expression":"KEY.reducesinkkey0","edgeType":"PROJECTION"}],"vertices":[{"id":0,"vertexType":"COLUMN","vertexId":"k"},{"id":1,"vertexType":"COLUMN","vertexId":"default.src1.key"},{"id":2,"vertexType":"COLUMN","vertexId":"default.src2.key2"}]} - -128 -146 -150 -213 -224 -238 -255 -273 -278 -311 -369 -401 -406 -66 -98 -PREHOOK: query: select key, count(1) a from dest1 group by key -PREHOOK: type: QUERY -PREHOOK: Input: default@dest1 -#### A masked pattern was here #### -{"version":"1.0","engine":"tez","database":"default","hash":"f74475552dc79e09d4e75116c0cc9f37","queryText":"select key, count(1) a from dest1 group by key","edges":[],"vertices":[]} -128 2 -213 2 -278 2 -369 2 - 20 -150 2 -238 2 -66 2 -146 2 -224 2 -255 2 -273 2 -311 2 -401 2 -406 2 -98 2 -PREHOOK: query: select key k, count(*) from dest1 group by key -PREHOOK: type: QUERY -PREHOOK: Input: default@dest1 -#### A masked pattern was here #### -{"version":"1.0","engine":"tez","database":"default","hash":"3a519d9badc7e8b87b42ba96a6f922ef","queryText":"select key k, count(*) from dest1 group by key","edges":[],"vertices":[]} -128 2 -213 2 -278 2 -369 2 - 20 -150 2 -238 2 -66 2 -146 2 -224 2 -255 2 -273 2 -311 2 -401 2 -406 2 -98 2 -PREHOOK: query: select key k, count(value) from dest1 group by key -PREHOOK: type: QUERY -PREHOOK: Input: default@dest1 -#### A masked pattern was here #### -{"version":"1.0","engine":"tez","database":"default","hash":"1253b0d8b57dc384abbcaa0fb30dff88","queryText":"select key k, count(value) from dest1 group by key","edges":[],"vertices":[]} -128 2 -213 2 -278 2 -369 2 - 20 -150 2 -238 2 -66 2 -146 2 -224 2 -255 2 -273 2 -311 2 -401 2 -406 2 -98 2 -PREHOOK: query: select value, max(length(key)) from dest1 group by value -PREHOOK: type: QUERY -PREHOOK: Input: default@dest1 -#### A masked pattern was here #### -{"version":"1.0","engine":"tez","database":"default","hash":"eb9155fd36ab5b8c92dc3c8c21be2378","queryText":"select value, max(length(key)) from dest1 group by value","edges":[],"vertices":[]} -val_146 3 -val_27 0 -val_409 0 -val_484 0 -val_66 2 - 3 -val_165 0 -val_238 3 -val_193 0 -val_213 3 -val_255 3 -val_265 0 -val_273 3 -val_278 3 -val_401 3 -val_150 3 -val_311 3 -val_406 3 -val_98 2 -PREHOOK: query: select value, max(length(key)) from dest1 group by value order by value limit 5 -PREHOOK: type: QUERY -PREHOOK: Input: default@dest1 -#### A masked pattern was here #### -{"version":"1.0","engine":"tez","database":"default","hash":"a2c41b381e538f6fa9e3df69171b6821","queryText":"select value, max(length(key)) from dest1 group by value order by value limit 5","edges":[{"sources":[2],"targets":[0],"edgeType":"PROJECTION"},{"sources":[3],"targets":[1],"expression":"max(length(dest1.key))","edgeType":"PROJECTION"}],"vertices":[{"id":0,"vertexType":"COLUMN","vertexId":"value"},{"id":1,"vertexType":"COLUMN","vertexId":"_c1"},{"id":2,"vertexType":"COLUMN","vertexId":"default.dest1.value"},{"id":3,"vertexType":"COLUMN","vertexId":"default.dest1.key"}]} - 3 -val_146 3 -val_150 3 -val_165 0 -val_193 0 -PREHOOK: query: select key, length(value) from dest1 -PREHOOK: type: QUERY -PREHOOK: Input: default@dest1 -#### A masked pattern was here #### -{"version":"1.0","engine":"tez","database":"default","hash":"70d589dfe8024d26cf9967f82928dc9b","queryText":"select key, length(value) from dest1","edges":[{"sources":[2],"targets":[0],"edgeType":"PROJECTION"},{"sources":[3],"targets":[1],"expression":"length(dest1.value)","edgeType":"PROJECTION"}],"vertices":[{"id":0,"vertexType":"COLUMN","vertexId":"key"},{"id":1,"vertexType":"COLUMN","vertexId":"_c1"},{"id":2,"vertexType":"COLUMN","vertexId":"default.dest1.key"},{"id":3,"vertexType":"COLUMN","vertexId":"default.dest1.value"}]} -238 7 - 0 -311 7 - 6 - 7 - 7 -255 7 -278 7 -98 6 - 7 - 7 - 7 -401 7 -150 7 -273 7 -224 0 -369 0 -66 6 -128 0 -213 7 -146 7 -406 7 - 0 - 0 - 0 -238 7 - 0 -311 7 - 6 - 7 - 7 -255 7 -278 7 -98 6 - 7 - 7 - 7 -401 7 -150 7 -273 7 -224 0 -369 0 -66 6 -128 0 -213 7 -146 7 -406 7 - 0 - 0 - 0 -PREHOOK: query: select length(value) + 3 from dest1 -PREHOOK: type: QUERY -PREHOOK: Input: default@dest1 -#### A masked pattern was here #### -{"version":"1.0","engine":"tez","database":"default","hash":"d8c94a817e6617916a194914823f5d3d","queryText":"select length(value) + 3 from dest1","edges":[{"sources":[1],"targets":[0],"expression":"(length(dest1.value) + 3)","edgeType":"PROJECTION"}],"vertices":[{"id":0,"vertexType":"COLUMN","vertexId":"_c0"},{"id":1,"vertexType":"COLUMN","vertexId":"default.dest1.value"}]} -10 -3 -10 -9 -10 -10 -10 -10 -9 -10 -10 -10 -10 -10 -10 -3 -3 -9 -3 -10 -10 -10 -3 -3 -3 -10 -3 -10 -9 -10 -10 -10 -10 -9 -10 -10 -10 -10 -10 -10 -3 -3 -9 -3 -10 -10 -10 -3 -3 -3 -PREHOOK: query: select 5 from dest1 -PREHOOK: type: QUERY -PREHOOK: Input: default@dest1 -#### A masked pattern was here #### -{"version":"1.0","engine":"tez","database":"default","hash":"1d0f7d94873fa1b019abd968a111ce22","queryText":"select 5 from dest1","edges":[{"sources":[],"targets":[0],"expression":"5","edgeType":"PROJECTION"}],"vertices":[{"id":0,"vertexType":"COLUMN","vertexId":"_c0"}]} -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -5 -PREHOOK: query: select 3 * 5 from dest1 -PREHOOK: type: QUERY -PREHOOK: Input: default@dest1 -#### A masked pattern was here #### -{"version":"1.0","engine":"tez","database":"default","hash":"7bc2c5b57493d06b7155218bc3d8e79c","queryText":"select 3 * 5 from dest1","edges":[{"sources":[],"targets":[0],"expression":"15","edgeType":"PROJECTION"}],"vertices":[{"id":0,"vertexType":"COLUMN","vertexId":"_c0"}]} -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -15 -PREHOOK: query: drop table if exists dest2 -PREHOOK: type: DROPTABLE -PREHOOK: query: create table dest2 as select * from src1 JOIN src2 ON src1.key = src2.key2 -PREHOOK: type: CREATETABLE_AS_SELECT -PREHOOK: Input: default@src1 -PREHOOK: Input: default@src2 -PREHOOK: Output: database:default -PREHOOK: Output: default@dest2 -{"version":"1.0","engine":"tez","database":"default","hash":"f4b699ec4c238c1070dd05649e4431dc","queryText":"create table dest2 as select * from src1 JOIN src2 ON src1.key = src2.key2","edges":[{"sources":[4],"targets":[0],"edgeType":"PROJECTION"},{"sources":[5],"targets":[1],"edgeType":"PROJECTION"},{"sources":[6],"targets":[2],"edgeType":"PROJECTION"},{"sources":[7],"targets":[3],"edgeType":"PROJECTION"},{"sources":[4],"targets":[0,1,2,3],"expression":"src1.key is not null","edgeType":"PREDICATE"},{"sources":[4,6],"targets":[0,1,2,3],"expression":"(src1.key = src2.key2)","edgeType":"PREDICATE"},{"sources":[6],"targets":[0,1,2,3],"expression":"src2.key2 is not null","edgeType":"PREDICATE"}],"vertices":[{"id":0,"vertexType":"COLUMN","vertexId":"default.dest2.key"},{"id":1,"vertexType":"COLUMN","vertexId":"default.dest2.value"},{"id":2,"vertexType":"COLUMN","vertexId":"default.dest2.key2"},{"id":3,"vertexType":"COLUMN","vertexId":"default.dest2.value2"},{"id":4,"vertexType":"COLUMN"," vertexId":"default.src1.key"},{"id":5,"vertexType":"COLUMN","vertexId":"default.src1.value"},{"id":6,"vertexType":"COLUMN","vertexId":"default.src2.key2"},{"id":7,"vertexType":"COLUMN","vertexId":"default.src2.value2"}]} -PREHOOK: query: insert overwrite table dest2 select * from src1 JOIN src2 ON src1.key = src2.key2 -PREHOOK: type: QUERY -PREHOOK: Input: default@src1 -PREHOOK: Input: default@src2 -PREHOOK: Output: default@dest2 -{"version":"1.0","engine":"tez","database":"default","hash":"3b021ad59d5c0c29a7d31f30adc34f00","queryText":"insert overwrite table dest2 select * from src1 JOIN src2 ON src1.key = src2.key2","edges":[{"sources":[4],"targets":[0],"expression":"compute_stats(default.src1.key, 'hll')","edgeType":"PROJECTION"},{"sources":[5],"targets":[1],"expression":"compute_stats(default.src1.value, 'hll')","edgeType":"PROJECTION"},{"sources":[6],"targets":[2],"expression":"compute_stats(default.src2.key2, 'hll')","edgeType":"PROJECTION"},{"sources":[7],"targets":[3],"expression":"compute_stats(default.src2.value2, 'hll')","edgeType":"PROJECTION"},{"sources":[4],"targets":[0,1,2,3],"expression":"src1.key is not null","edgeType":"PREDICATE"},{"sources":[4,6],"targets":[0,1,2,3],"expression":"(src1.key = src2.key2)","edgeType":"PREDICATE"},{"sources":[6],"targets":[0,1,2,3],"expression":"src2.key2 is not null","edgeType":"PREDICATE"}],"vertices":[{"id":0,"vertexType":"COLUMN","vertexId":"default.dest2. key"},{"id":1,"vertexType":"COLUMN","vertexId":"default.dest2.value"},{"id":2,"vertexType":"COLUMN","vertexId":"default.dest2.key2"},{"id":3,"vertexType":"COLUMN","vertexId":"default.dest2.value2"},{"id":4,"vertexType":"COLUMN","vertexId":"default.src1.key"},{"id":5,"vertexType":"COLUMN","vertexId":"default.src1.value"},{"id":6,"vertexType":"COLUMN","vertexId":"default.src2.key2"},{"id":7,"vertexType":"COLUMN","vertexId":"default.src2.value2"}]} -PREHOOK: query: insert into table dest2 select * from src1 JOIN src2 ON src1.key = src2.key2 -PREHOOK: type: QUERY -PREHOOK: Input: default@src1 -PREHOOK: Input: default@src2 -PREHOOK: Output: default@dest2 -{"version":"1.0","engine":"tez","database":"default","hash":"af307ac1d300fa5d01bb565bde9c43bf","queryText":"insert into table dest2 select * from src1 JOIN src2 ON src1.key = src2.key2","edges":[{"sources":[4],"targets":[0],"expression":"compute_stats(default.src1.key, 'hll')","edgeType":"PROJECTION"},{"sources":[5],"targets":[1],"expression":"compute_stats(default.src1.value, 'hll')","edgeType":"PROJECTION"},{"sources":[6],"targets":[2],"expression":"compute_stats(default.src2.key2, 'hll')","edgeType":"PROJECTION"},{"sources":[7],"targets":[3],"expression":"compute_stats(default.src2.value2, 'hll')","edgeType":"PROJECTION"},{"sources":[4],"targets":[0,1,2,3],"expression":"src1.key is not null","edgeType":"PREDICATE"},{"sources":[4,6],"targets":[0,1,2,3],"expression":"(src1.key = src2.key2)","edgeType":"PREDICATE"},{"sources":[6],"targets":[0,1,2,3],"expression":"src2.key2 is not null","edgeType":"PREDICATE"}],"vertices":[{"id":0,"vertexType":"COLUMN","vertexId":"default.dest2.key"} ,{"id":1,"vertexType":"COLUMN","vertexId":"default.dest2.value"},{"id":2,"vertexType":"COLUMN","vertexId":"default.dest2.key2"},{"id":3,"vertexType":"COLUMN","vertexId":"default.dest2.value2"},{"id":4,"vertexType":"COLUMN","vertexId":"default.src1.key"},{"id":5,"vertexType":"COLUMN","vertexId":"default.src1.value"},{"id":6,"vertexType":"COLUMN","vertexId":"default.src2.key2"},{"id":7,"vertexType":"COLUMN","vertexId":"default.src2.value2"}]} -PREHOOK: query: insert into table dest2 - select * from src1 JOIN src2 ON length(src1.value) = length(src2.value2) + 1 -PREHOOK: type: QUERY -PREHOOK: Input: default@src1 -PREHOOK: Input: default@src2 -PREHOOK: Output: default@dest2 -{"version":"1.0","engine":"tez","database":"default","hash":"f48c483220ee1ff585752846ce4f3158","queryText":"insert into table dest2\n select * from src1 JOIN src2 ON length(src1.value) = length(src2.value2) + 1","edges":[{"sources":[4],"targets":[0],"expression":"compute_stats(default.src1.key, 'hll')","edgeType":"PROJECTION"},{"sources":[5],"targets":[1],"expression":"compute_stats(default.src1.value, 'hll')","edgeType":"PROJECTION"},{"sources":[6],"targets":[2],"expression":"compute_stats(default.src2.key2, 'hll')","edgeType":"PROJECTION"},{"sources":[7],"targets":[3],"expression":"compute_stats(default.src2.value2, 'hll')","edgeType":"PROJECTION"},{"sources":[5],"targets":[0,1,2,3],"expression":"length(src1.value) is not null","edgeType":"PREDICATE"},{"sources":[5,7],"targets":[0,1,2,3],"expression":"(length(src1.value) = (length(src2.value2) + 1))","edgeType":"PREDICATE"},{"sources":[7],"targets":[0,1,2,3],"expression":"length(src2.value2) is not null","edgeType":"PREDICATE"}], "vertices":[{"id":0,"vertexType":"COLUMN","vertexId":"default.dest2.key"},{"id":1,"vertexType":"COLUMN","vertexId":"default.dest2.value"},{"id":2,"vertexType":"COLUMN","vertexId":"default.dest2.key2"},{"id":3,"vertexType":"COLUMN","vertexId":"default.dest2.value2"},{"id":4,"vertexType":"COLUMN","vertexId":"default.src1.key"},{"id":5,"vertexType":"COLUMN","vertexId":"default.src1.value"},{"id":6,"vertexType":"COLUMN","vertexId":"default.src2.key2"},{"id":7,"vertexType":"COLUMN","vertexId":"default.src2.value2"}]} -PREHOOK: query: select * from src1 where length(key) > 2 -PREHOOK: type: QUERY -PREHOOK: Input: default@src1 -#### A masked pattern was here #### -{"version":"1.0","engine":"tez","database":"default","hash":"209345b4bbf01ad0a77037007f694912","queryText":"select * from src1 where length(key) > 2","edges":[{"sources":[2],"targets":[0],"edgeType":"PROJECTION"},{"sources":[3],"targets":[1],"edgeType":"PROJECTION"},{"sources":[2],"targets":[0,1],"expression":"(length(src1.key) > 2)","edgeType":"PREDICATE"}],"vertices":[{"id":0,"vertexType":"COLUMN","vertexId":"src1.key"},{"id":1,"vertexType":"COLUMN","vertexId":"src1.value"},{"id":2,"vertexType":"COLUMN","vertexId":"default.src1.key"},{"id":3,"vertexType":"COLUMN","vertexId":"default.src1.value"}]} -238 val_238 -311 val_311 -255 val_255 -278 val_278 -401 val_401 -150 val_150 -273 val_273 -224 -369 -128 -213 val_213 -146 val_146 -406 val_406 -PREHOOK: query: select * from src1 where length(key) > 2 and value > 'a' -PREHOOK: type: QUERY -PREHOOK: Input: default@src1 -#### A masked pattern was here #### -{"version":"1.0","engine":"tez","database":"default","hash":"f4a6b14cf6ce3c1313d70720cea4e8b3","queryText":"select * from src1 where length(key) > 2 and value > 'a'","edges":[{"sources":[2],"targets":[0],"edgeType":"PROJECTION"},{"sources":[3],"targets":[1],"edgeType":"PROJECTION"},{"sources":[2,3],"targets":[0,1],"expression":"((length(src1.key) > 2) and (src1.value > 'a'))","edgeType":"PREDICATE"}],"vertices":[{"id":0,"vertexType":"COLUMN","vertexId":"src1.key"},{"id":1,"vertexType":"COLUMN","vertexId":"src1.value"},{"id":2,"vertexType":"COLUMN","vertexId":"default.src1.key"},{"id":3,"vertexType":"COLUMN","vertexId":"default.src1.value"}]} -238 val_238 -311 val_311 -255 val_255 -278 val_278 -401 val_401 -150 val_150 -273 val_273 -213 val_213 -146 val_146 -406 val_406 -PREHOOK: query: drop table if exists dest3 -PREHOOK: type: DROPTABLE -PREHOOK: query: create table dest3 as - select * from src1 JOIN src2 ON src1.key = src2.key2 WHERE length(key) > 1 -PREHOOK: type: CREATETABLE_AS_SELECT -PREHOOK: Input: default@src1 -PREHOOK: Input: default@src2 -PREHOOK: Output: database:default -PREHOOK: Output: default@dest3 -{"version":"1.0","engine":"tez","database":"default","hash":"c655c518950fe945d0a5eca84fbbe72d","queryText":"create table dest3 as\n select * from src1 JOIN src2 ON src1.key = src2.key2 WHERE length(key) > 1","edges":[{"sources":[4],"targets":[0],"edgeType":"PROJECTION"},{"sources":[5],"targets":[1],"edgeType":"PROJECTION"},{"sources":[6],"targets":[2],"edgeType":"PROJECTION"},{"sources":[7],"targets":[3],"edgeType":"PROJECTION"},{"sources":[4],"targets":[0,1,2,3],"expression":"((length(src1.key) > 1) and src1.key is not null)","edgeType":"PREDICATE"},{"sources":[4,6],"targets":[0,1,2,3],"expression":"(src1.key = src2.key2)","edgeType":"PREDICATE"},{"sources":[6],"targets":[0,1,2,3],"expression":"((length(src2.key2) > 1) and src2.key2 is not null)","edgeType":"PREDICATE"}],"vertices":[{"id":0,"vertexType":"COLUMN","vertexId":"default.dest3.key"},{"id":1,"vertexType":"COLUMN","vertexId":"default.dest3.value"},{"id":2,"vertexType":"COLUMN","vertexId":"default.dest3.key2"},{"id":3,"ver texType":"COLUMN","vertexId":"default.dest3.value2"},{"id":4,"vertexType":"COLUMN","vertexId":"default.src1.key"},{"id":5,"vertexType":"COLUMN","vertexId":"default.src1.value"},{"id":6,"vertexType":"COLUMN","vertexId":"default.src2.key2"},{"id":7,"vertexType":"COLUMN","vertexId":"default.src2.value2"}]} -PREHOOK: query: insert overwrite table dest2 - select * from src1 JOIN src2 ON src1.key = src2.key2 WHERE length(key) > 3 -PREHOOK: type: QUERY -PREHOOK: Input: default@src1 -PREHOOK: Input: default@src2 -PREHOOK: Output: default@dest2 -{"version":"1.0","engine":"tez","database":"default","hash":"591a3e7ec854313a3d9c31b04a974739","queryText":"insert overwrite table dest2\n select * from src1 JOIN src2 ON src1.key = src2.key2 WHERE length(key) > 3","edges":[{"sources":[4],"targets":[0],"expression":"compute_stats(default.src1.key, 'hll')","edgeType":"PROJECTION"},{"sources":[5],"targets":[1],"expression":"compute_stats(default.src1.value, 'hll')","edgeType":"PROJECTION"},{"sources":[6],"targets":[2],"expression":"compute_stats(default.src2.key2, 'hll')","edgeType":"PROJECTION"},{"sources":[7],"targets":[3],"expression":"compute_stats(default.src2.value2, 'hll')","edgeType":"PROJECTION"},{"sources":[4],"targets":[0,1,2,3],"expression":"((length(src1.key) > 3) and src1.key is not null)","edgeType":"PREDICATE"},{"sources":[4,6],"targets":[0,1,2,3],"expression":"(src1.key = src2.key2)","edgeType":"PREDICATE"},{"sources":[6],"targets":[0,1,2,3],"expression":"((length(src2.key2) > 3) and src2.key2 is not null)","edgeType ":"PREDICATE"}],"vertices":[{"id":0,"vertexType":"COLUMN","vertexId":"default.dest2.key"},{"id":1,"vertexType":"COLUMN","vertexId":"default.dest2.value"},{"id":2,"vertexType":"COLUMN","vertexId":"default.dest2.key2"},{"id":3,"vertexType":"COLUMN","vertexId":"default.dest2.value2"},{"id":4,"vertexType":"COLUMN","vertexId":"default.src1.key"},{"id":5,"vertexType":"COLUMN","vertexId":"default.src1.value"},{"id":6,"vertexType":"COLUMN","vertexId":"default.src2.key2"},{"id":7,"vertexType":"COLUMN","vertexId":"default.src2.value2"}]} -PREHOOK: query: drop table if exists dest_l1 -PREHOOK: type: DROPTABLE -PREHOOK: query: CREATE TABLE dest_l1(key INT, value STRING) STORED AS TEXTFILE -PREHOOK: type: CREATETABLE -PREHOOK: Output: database:default -PREHOOK: Output: default@dest_l1 -PREHOOK: query: INSERT OVERWRITE TABLE dest_l1 -SELECT j.* -FROM (SELECT t1.key, p1.value - FROM src1 t1 - LEFT OUTER JOIN src p1 - ON (t1.key = p1.key) - UNION ALL - SELECT t2.key, p2.value - FROM src1 t2 - LEFT OUTER JOIN src p2 - ON (t2.key = p2.key)) j -PREHOOK: type: QUERY -PREHOOK: Input: default@src -PREHOOK: Input: default@src1 -PREHOOK: Output: default@dest_l1 -{"version":"1.0","engine":"tez","database":"default","hash":"f92e96c6357273ea6cbb2195a418df9c","queryText":"INSERT OVERWRITE TABLE dest_l1\nSELECT j.*\nFROM (SELECT t1.key, p1.value\n FROM src1 t1\n LEFT OUTER JOIN src p1\n ON (t1.key = p1.key)\n UNION ALL\n SELECT t2.key, p2.value\n FROM src1 t2\n LEFT OUTER JOIN src p2\n ON (t2.key = p2.key)) j","edges":[{"sources":[2],"targets":[0],"expression":"UDFToInteger(key)","edgeType":"PROJECTION"},{"sources":[3],"targets":[1],"expression":"value","edgeType":"PROJECTION"},{"sources":[4,2],"targets":[0,1],"expression":"(j-subquery1:_u1-subquery1:p1.key = j-subquery1:_u1-subquery1:t1.key)","edgeType":"PREDICATE"},{"sources":[4,2],"targets":[0,1],"expression":"(j-subquery2:_u1-subquery2:p2.key = j-subquery2:_u1-subquery2:t2.key)","edgeType":"PREDICATE"},{"sources":[2],"targets":[0],"expression":"compute_stats(UDFToInteger(key), 'hll')","edgeType":"PROJECTION"},{"sources":[3],"targets":[1],"expression":" compute_stats(value, 'hll')","edgeType":"PROJECTION"}],"vertices":[{"id":0,"vertexType":"COLUMN","vertexId":"default.dest_l1.key"},{"id":1,"vertexType":"COLUMN","vertexId":"default.dest_l1.value"},{"id":2,"vertexType":"COLUMN","vertexId":"default.src1.key"},{"id":3,"vertexType":"COLUMN","vertexId":"default.src.value"},{"id":4,"vertexType":"COLUMN","vertexId":"default.src.key"}]} -PREHOOK: query: drop table if exists emp -PREHOOK: type: DROPTABLE -PREHOOK: query: drop table if exists dept -PREHOOK: type: DROPTABLE -PREHOOK: query: drop table if exists project -PREHOOK: type: DROPTABLE -PREHOOK: query: drop table if exists tgt -PREHOOK: type: DROPTABLE -PREHOOK: query: create table emp(emp_id int, name string, mgr_id int, dept_id int) -PREHOOK: type: CREATETABLE -PREHOOK: Output: database:default -PREHOOK: Output: default@emp -PREHOOK: query: create table dept(dept_id int, dept_name string) -PREHOOK: type: CREATETABLE -PREHOOK: Output: database:default -PREHOOK: Output: default@dept -PREHOOK: query: create table project(project_id int, project_name string) -PREHOOK: type: CREATETABLE -PREHOOK: Output: database:default -PREHOOK: Output: default@project -PREHOOK: query: create table tgt(dept_name string, name string, - emp_id int, mgr_id int, proj_id int, proj_name string) -PREHOOK: type: CREATETABLE -PREHOOK: Output: database:default -PREHOOK: Output: default@tgt -PREHOOK: query: INSERT INTO TABLE tgt -SELECT emd.dept_name, emd.name, emd.emp_id, emd.mgr_id, p.project_id, p.project_name -FROM ( - SELECT d.dept_name, em.name, em.emp_id, em.mgr_id, em.dept_id - FROM ( - SELECT e.name, e.dept_id, e.emp_id emp_id, m.emp_id mgr_id - FROM emp e JOIN emp m ON e.emp_id = m.emp_id - ) em - JOIN dept d ON d.dept_id = em.dept_id - ) emd JOIN project p ON emd.dept_id = p.project_id -PREHOOK: type: QUERY -PREHOOK: Input: default@dept -PREHOOK: Input: default@emp -PREHOOK: Input: default@project -PREHOOK: Output: default@tgt -{"version":"1.0","engine":"tez","database":"default","hash":"6ace89578a35c75847177f15e548eb82","queryText":"INSERT INTO TABLE tgt\nSELECT emd.dept_name, emd.name, emd.emp_id, emd.mgr_id, p.project_id, p.project_name\nFROM (\n SELECT d.dept_name, em.name, em.emp_id, em.mgr_id, em.dept_id\n FROM (\n SELECT e.name, e.dept_id, e.emp_id emp_id, m.emp_id mgr_id\n FROM emp e JOIN emp m ON e.emp_id = m.emp_id\n ) em\n JOIN dept d ON d.dept_id = em.dept_id\n ) emd JOIN project p ON emd.dept_id = p.project_id","edges":[{"sources":[6],"targets":[0],"edgeType":"PROJECTION"},{"sources":[7],"targets":[1],"edgeType":"PROJECTION"},{"sources":[8],"targets":[2,3],"edgeType":"PROJECTION"},{"sources":[9],"targets":[4],"edgeType":"PROJECTION"},{"sources":[10],"targets":[5],"edgeType":"PROJECTION"},{"sources":[8,11],"targets":[0,1,2,3,4,5],"expression":"(e.emp_id is not null and e.dept_id is not null)","edgeType":"PREDICATE"},{"sources":[8],"targets":[0,1,2,3,4,5],"expression":"(emd:em:e.emp _id = emd:em:m.emp_id)","edgeType":"PREDICATE"},{"sources":[8],"targets":[0,1,2,3,4,5],"expression":"m.emp_id is not null","edgeType":"PREDICATE"},{"sources":[11,12,9],"targets":[0,1,2,3,4,5],"expression":"(emd:em:e.dept_id = emd:d.dept_id AND emd:em:e.dept_id = p.project_id)","edgeType":"PREDICATE"},{"sources":[12],"targets":[0,1,2,3,4,5],"expression":"d.dept_id is not null","edgeType":"PREDICATE"},{"sources":[9],"targets":[0,1,2,3,4,5],"expression":"p.project_id is not null","edgeType":"PREDICATE"},{"sources":[6],"targets":[0],"expression":"compute_stats(default.dept.dept_name, 'hll')","edgeType":"PROJECTION"},{"sources":[7],"targets":[1],"expression":"compute_stats(default.emp.name, 'hll')","edgeType":"PROJECTION"},{"sources":[8],"targets":[2,3],"expression":"compute_stats(default.emp.emp_id, 'hll')","edgeType":"PROJECTION"},{"sources":[9],"targets":[4],"expression":"compute_stats(default.project.project_id, 'hll')","edgeType":"PROJECTION"},{"sources":[10],"targets":[5],"expressi on":"compute_stats(default.project.project_name, 'hll')","edgeType":"PROJECTION"}],"vertices":[{"id":0,"vertexType":"COLUMN","vertexId":"default.tgt.dept_name"},{"id":1,"vertexType":"COLUMN","vertexId":"default.tgt.name"},{"id":2,"vertexType":"COLUMN","vertexId":"default.tgt.emp_id"},{"id":3,"vertexType":"COLUMN","vertexId":"default.tgt.mgr_id"},{"id":4,"vertexType":"COLUMN","vertexId":"default.tgt.proj_id"},{"id":5,"vertexType":"COLUMN","vertexId":"default.tgt.proj_name"},{"id":6,"vertexType":"COLUMN","vertexId":"default.dept.dept_name"},{"id":7,"vertexType":"COLUMN","vertexId":"default.emp.name"},{"id":8,"vertexType":"COLUMN","vertexId":"default.emp.emp_id"},{"id":9,"vertexType":"COLUMN","vertexId":"default.project.project_id"},{"id":10,"vertexType":"COLUMN","vertexId":"default.project.project_name"},{"id":11,"vertexType":"COLUMN","vertexId":"default.emp.dept_id"},{"id":12,"vertexType":"COLUMN","vertexId":"default.dept.dept_id"}]} -PREHOOK: query: drop table if exists dest_l2 -PREHOOK: type: DROPTABLE -PREHOOK: query: create table dest_l2 (id int, c1 tinyint, c2 int, c3 bigint) stored as textfile -PREHOOK: type: CREATETABLE -PREHOOK: Output: database:default -PREHOOK: Output: default@dest_l2 -PREHOOK: query: insert into dest_l2 values(0, 1, 100, 10000) -PREHOOK: type: QUERY -PREHOOK: Output: default@dest_l2 -{"version":"1.0","engine":"tez","database":"default","hash":"f9a01e400eb50cc3c5ec0741ed20994c","queryText":"insert into dest_l2 values(0, 1, 100, 10000)","edges":[{"sources":[],"targets":[0],"expression":"UDFToInteger(tmp_values_col1)","edgeType":"PROJECTION"},{"sources":[],"targets":[1],"expression":"UDFToByte(tmp_values_col2)","edgeType":"PROJECTION"},{"sources":[],"targets":[2],"expression":"UDFToInteger(tmp_values_col3)","edgeType":"PROJECTION"},{"sources":[],"targets":[3],"expression":"UDFToLong(tmp_values_col4)","edgeType":"PROJECTION"},{"sources":[],"targets":[0],"expression":"compute_stats(UDFToInteger(tmp_values_col1), 'hll')","edgeType":"PROJECTION"},{"sources":[],"targets":[1],"expression":"compute_stats(UDFToByte(tmp_values_col2), 'hll')","edgeType":"PROJECTION"},{"sources":[],"targets":[2],"expression":"compute_stats(UDFToInteger(tmp_values_col3), 'hll')","edgeType":"PROJECTION"},{"sources":[],"targets":[3],"expression":"compute_stats(UDFToLong(tmp_values_col4), 'hll')" ,"edgeType":"PROJECTION"}],"vertices":[{"id":0,"vertexType":"COLUMN","vertexId":"default.dest_l2.id"},{"id":1,"vertexType":"COLUMN","vertexId":"default.dest_l2.c1"},{"id":2,"vertexType":"COLUMN","vertexId":"default.dest_l2.c2"},{"id":3,"vertexType":"COLUMN","vertexId":"default.dest_l2.c3"}]} -PREHOOK: query: select * from ( - select c1 + c2 x from dest_l2 - union all - select sum(c3) y from (select c3 from dest_l2) v1) v2 order by x -PREHOOK: type: QUERY -PREHOOK: Input: default@dest_l2 -#### A masked pattern was here #### -{"version":"1.0","engine":"tez","database":"default","hash":"4463cf621f146cd06d9dc841259dcd91","queryText":"select * from (\n select c1 + c2 x from dest_l2\n union all\n select sum(c3) y from (select c3 from dest_l2) v1) v2 order by x","edges":[{"sources":[1,2,3],"targets":[0],"expression":"KEY.reducesinkkey0","edgeType":"PROJECTION"}],"vertices":[{"id":0,"vertexType":"COLUMN","vertexId":"v2.x"},{"id":1,"vertexType":"COLUMN","vertexId":"default.dest_l2.c1"},{"id":2,"vertexType":"COLUMN","vertexId":"default.dest_l2.c2"},{"id":3,"vertexType":"COLUMN","vertexId":"default.dest_l2.c3"}]} -101 -10000 -PREHOOK: query: drop table if exists dest_l3 -PREHOOK: type: DROPTABLE -PREHOOK: query: create table dest_l3 (id int, c1 string, c2 string, c3 int) stored as textfile -PREHOOK: type: CREATETABLE -PREHOOK: Output: database:default -PREHOOK: Output: default@dest_l3 -PREHOOK: query: insert into dest_l3 values(0, "s1", "s2", 15) -PREHOOK: type: QUERY -PREHOOK: Output: default@dest_l3 -{"version":"1.0","engine":"tez","database":"default","hash":"9f432e7641bec615db3eb365daa3eeae","queryText":"insert into dest_l3 values(0, \"s1\", \"s2\", 15)","edges":[{"sources":[],"targets":[0],"expression":"UDFToInteger(tmp_values_col1)","edgeType":"PROJECTION"},{"sources":[],"targets":[1,2],"edgeType":"PROJECTION"},{"sources":[],"targets":[3],"expression":"UDFToInteger(tmp_values_col4)","edgeType":"PROJECTION"},{"sources":[],"targets":[0],"expression":"compute_stats(UDFToInteger(tmp_values_col1), 'hll')","edgeType":"PROJECTION"},{"sources":[],"targets":[1],"expression":"compute_stats(default.values__tmp__table__2.tmp_values_col2, 'hll')","edgeType":"PROJECTION"},{"sources":[],"targets":[2],"expression":"compute_stats(default.values__tmp__table__2.tmp_values_col3, 'hll')","edgeType":"PROJECTION"},{"sources":[],"targets":[3],"expression":"compute_stats(UDFToInteger(tmp_values_col4), 'hll')","edgeType":"PROJECTION"}],"vertices":[{"id":0,"vertexType":"COLUMN","vertexId":"default.des t_l3.id"},{"id":1,"vertexType":"COLUMN","vertexId":"default.dest_l3.c1"},{"id":2,"vertexType":"COLUMN","vertexId":"default.dest_l3.c2"},{"id":3,"vertexType":"COLUMN","vertexId":"default.dest_l3.c3"}]} -PREHOOK: query: select sum(a.c1) over (partition by a.c1 order by a.id) -from dest_l2 a -where a.c2 != 10 -group by a.c1, a.c2, a.id -having count(a.c2) > 0 -PREHOOK: type: QUERY -PREHOOK: Input: default@dest_l2 -#### A masked pattern was here #### -{"version":"1.0","engine":"tez","database":"default","hash":"4e60ca1e72d985639b2027021a199297","queryText":"select sum(a.c1) over (partition by a.c1 order by a.id)\nfrom dest_l2 a\nwhere a.c2 != 10\ngroup by a.c1, a.c2, a.id\nhaving count(a.c2) > 0","edges":[{"sources":[1,2,3],"targets":[0],"expression":"$win$_col_0","edgeType":"PROJECTION"},{"sources":[2],"targets":[0],"expression":"(a.c2 <> 10)","edgeType":"PREDICATE"},{"sources":[2],"targets":[0],"expression":"(count(default.dest_l2.c2) > 0)","edgeType":"PREDICATE"}],"vertices":[{"id":0,"vertexType":"COLUMN","vertexId":"_c0"},{"id":1,"vertexType":"COLUMN","vertexId":"default.dest_l2.c1"},{"id":2,"vertexType":"COLUMN","vertexId":"default.dest_l2.c2"},{"id":3,"vertexType":"COLUMN","vertexId":"default.dest_l2.id"}]} -1 -PREHOOK: query: select sum(a.c1), count(b.c1), b.c2, b.c3 -from dest_l2 a join dest_l3 b on (a.id = b.id) -where a.c2 != 10 and b.c3 > 0 -group by a.c1, a.c2, a.id, b.c1, b.c2, b.c3 -having count(a.c2) > 0 -order by b.c3 limit 5 -PREHOOK: type: QUERY -PREHOOK: Input: default@dest_l2 -PREHOOK: Input: default@dest_l3 -#### A masked pattern was here #### -{"version":"1.0","engine":"tez","database":"default","hash":"0dc990e844acc6c8309f674a4ca281d2","queryText":"select sum(a.c1), count(b.c1), b.c2, b.c3\nfrom dest_l2 a join dest_l3 b on (a.id = b.id)\nwhere a.c2 != 10 and b.c3 > 0\ngroup by a.c1, a.c2, a.id, b.c1, b.c2, b.c3\nhaving count(a.c2) > 0\norder by b.c3 limit 5","edges":[{"sources":[4],"targets":[0],"expression":"sum(default.dest_l2.c1)","edgeType":"PROJECTION"},{"sources":[5],"targets":[1],"expression":"count(default.dest_l3.c1)","edgeType":"PROJECTION"},{"sources":[6],"targets":[2],"edgeType":"PROJECTION"},{"sources":[7],"targets":[3],"edgeType":"PROJECTION"},{"sources":[8,9],"targets":[0,1,2,3],"expression":"((a.c2 <> 10) and a.id is not null)","edgeType":"PREDICATE"},{"sources":[9,10],"targets":[0,1,2,3],"expression":"(a.id = b.id)","edgeType":"PREDICATE"},{"sources":[7,10],"targets":[0,1,2,3],"expression":"((b.c3 > 0) and b.id is not null)","edgeType":"PREDICATE"},{"sources":[8],"targets":[0,1,2,3],"expression":"(count( default.dest_l2.c2) > 0)","edgeType":"PREDICATE"}],"vertices":[{"id":0,"vertexType":"COLUMN","vertexId":"_c0"},{"id":1,"vertexType":"COLUMN","vertexId":"_c1"},{"id":2,"vertexType":"COLUMN","vertexId":"b.c2"},{"id":3,"vertexType":"COLUMN","vertexId":"b.c3"},{"id":4,"vertexType":"COLUMN","vertexId":"default.dest_l2.c1"},{"id":5,"vertexType":"COLUMN","vertexId":"default.dest_l3.c1"},{"id":6,"vertexType":"COLUMN","vertexId":"default.dest_l3.c2"},{"id":7,"vertexType":"COLUMN","vertexId":"default.dest_l3.c3"},{"id":8,"vertexType":"COLUMN","vertexId":"default.dest_l2.c2"},{"id":9,"vertexType":"COLUMN","vertexId":"default.dest_l2.id"},{"id":10,"vertexType":"COLUMN","vertexId":"default.dest_l3.id"}]} -1 1 s2 15 -PREHOOK: query: drop table if exists t -PREHOOK: type: DROPTABLE -PREHOOK: query: create table t as -select distinct a.c2, a.c3 from dest_l2 a -inner join dest_l3 b on (a.id = b.id) -where a.id > 0 and b.c3 = 15 -PREHOOK: type: CREATETABLE_AS_SELECT -PREHOOK: Input: default@dest_l2 -PREHOOK: Input: default@dest_l3 -PREHOOK: Output: database:default -PREHOOK: Output: default@t -{"version":"1.0","engine":"tez","database":"default","hash":"1e5560b3baadb92fba1bccf620ae5c87","queryText":"create table t as\nselect distinct a.c2, a.c3 from dest_l2 a\ninner join dest_l3 b on (a.id = b.id)\nwhere a.id > 0 and b.c3 = 15","edges":[{"sources":[2],"targets":[0],"edgeType":"PROJECTION"},{"sources":[3],"targets":[1],"edgeType":"PROJECTION"},{"sources":[4],"targets":[0,1],"expression":"(a.id > 0)","edgeType":"PREDICATE"},{"sources":[4,5],"targets":[0,1],"expression":"(a.id = b.id)","edgeType":"PREDICATE"},{"sources":[6,5],"targets":[0,1],"expression":"((b.c3 = 15) and (b.id > 0))","edgeType":"PREDICATE"}],"vertices":[{"id":0,"vertexType":"COLUMN","vertexId":"default.t.c2"},{"id":1,"vertexType":"COLUMN","vertexId":"default.t.c3"},{"id":2,"vertexType":"COLUMN","vertexId":"default.dest_l2.c2"},{"id":3,"vertexType":"COLUMN","vertexId":"default.dest_l2.c3"},{"id":4,"vertexType":"COLUMN","vertexId":"default.dest_l2.id"},{"id":5,"vertexType":"COLUMN","vertexId":"default.dest_l3 .id"},{"id":6,"vertexType":"COLUMN","vertexId":"default.dest_l3.c3"}]} -PREHOOK: query: SELECT substr(src1.key,1,1), count(DISTINCT substr(src1.value,5)), -concat(substr(src1.key,1,1),sum(substr(src1.value,5))) -from src1 -GROUP BY substr(src1.key,1,1) -PREHOOK: type: QUERY -PREHOOK: Input: default@src1 -#### A masked pattern was here #### -{"version":"1.0","engine":"tez","database":"default","hash":"45647e8609e1738841f557398ea52e7f","queryText":"SELECT substr(src1.key,1,1), count(DISTINCT substr(src1.value,5)),\nconcat(substr(src1.key,1,1),sum(substr(src1.value,5)))\nfrom src1\nGROUP BY substr(src1.key,1,1)","edges":[{"sources":[3],"targets":[0],"expression":"substr(src1.key, 1, 1)","edgeType":"PROJECTION"},{"sources":[4],"targets":[1],"expression":"count(DISTINCT KEY._col1:0._col0)","edgeType":"PROJECTION"},{"sources":[3,5],"targets":[2],"expression":"concat(substr(src1.key, 1, 1), sum(substr(src1.value, 5)))","edgeType":"PROJECTION"}],"vertices":[{"id":0,"vertexType":"COLUMN","vertexId":"_c0"},{"id":1,"vertexType":"COLUMN","vertexId":"_c1"},{"id":2,"vertexType":"COLUMN","vertexId":"_c2"},{"id":3,"vertexType":"COLUMN","vertexId":"default.src1.key"},{"id":4,"vertexType":"TABLE","vertexId":"default.src1"},{"id":5,"vertexType":"COLUMN","vertexId":"default.src1.value"}]} - 7 1543.0 -1 3 1296.0 -2 6 21257.0 -3 2 3311.0 -4 2 4807.0 -6 1 666.0 -9 1 998.0 http://git-wip-us.apache.org/repos/asf/hive/blob/7e64114d/ql/src/test/results/clientpositive/llap/columnStatsUpdateForStatsOptimizer_1.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/llap/columnStatsUpdateForStatsOptimizer_1.q.out b/ql/src/test/results/clientpositive/llap/columnStatsUpdateForStatsOptimizer_1.q.out index c60a5be..fb7e872 100644 --- a/ql/src/test/results/clientpositive/llap/columnStatsUpdateForStatsOptimizer_1.q.out +++ b/ql/src/test/results/clientpositive/llap/columnStatsUpdateForStatsOptimizer_1.q.out @@ -12,12 +12,14 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@calendar PREHOOK: query: insert into calendar values (2010, 10), (2011, 11), (2012, 12) PREHOOK: type: QUERY +PREHOOK: Input: _dummy_database@_dummy_table PREHOOK: Output: default@calendar POSTHOOK: query: insert into calendar values (2010, 10), (2011, 11), (2012, 12) POSTHOOK: type: QUERY +POSTHOOK: Input: _dummy_database@_dummy_table POSTHOOK: Output: default@calendar -POSTHOOK: Lineage: calendar.month EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] -POSTHOOK: Lineage: calendar.year EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] +POSTHOOK: Lineage: calendar.month SCRIPT [] +POSTHOOK: Lineage: calendar.year SCRIPT [] PREHOOK: query: desc formatted calendar PREHOOK: type: DESCTABLE PREHOOK: Input: default@calendar @@ -253,12 +255,14 @@ POSTHOOK: Input: default@calendar 2012 PREHOOK: query: insert into calendar values (2015, 15) PREHOOK: type: QUERY +PREHOOK: Input: _dummy_database@_dummy_table PREHOOK: Output: default@calendar POSTHOOK: query: insert into calendar values (2015, 15) POSTHOOK: type: QUERY +POSTHOOK: Input: _dummy_database@_dummy_table POSTHOOK: Output: default@calendar -POSTHOOK: Lineage: calendar.month EXPRESSION [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col2, type:string, comment:), ] -POSTHOOK: Lineage: calendar.year EXPRESSION [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col1, type:string, comment:), ] +POSTHOOK: Lineage: calendar.month SCRIPT [] +POSTHOOK: Lineage: calendar.year SCRIPT [] PREHOOK: query: desc formatted calendar PREHOOK: type: DESCTABLE PREHOOK: Input: default@calendar @@ -638,11 +642,13 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@calendarp PREHOOK: query: insert into table calendarp partition (p=1) values (2010), (2011), (2012) PREHOOK: type: QUERY +PREHOOK: Input: _dummy_database@_dummy_table PREHOOK: Output: default@calendarp@p=1 POSTHOOK: query: insert into table calendarp partition (p=1) values (2010), (2011), (2012) POSTHOOK: type: QUERY +POSTHOOK: Input: _dummy_database@_dummy_table POSTHOOK: Output: default@calendarp@p=1 -POSTHOOK: Lineage: calendarp PARTITION(p=1).year EXPRESSION [(values__tmp__table__3)values__tmp__table__3.FieldSchema(name:tmp_values_col1, type:string, comment:), ] +POSTHOOK: Lineage: calendarp PARTITION(p=1).year SCRIPT [] PREHOOK: query: desc formatted calendarp partition (p=1) PREHOOK: type: DESCTABLE PREHOOK: Input: default@calendarp @@ -814,11 +820,13 @@ STAGE PLANS: PREHOOK: query: insert into table calendarp partition (p=1) values (2015) PREHOOK: type: QUERY +PREHOOK: Input: _dummy_database@_dummy_table PREHOOK: Output: default@calendarp@p=1 POSTHOOK: query: insert into table calendarp partition (p=1) values (2015) POSTHOOK: type: QUERY +POSTHOOK: Input: _dummy_database@_dummy_table POSTHOOK: Output: default@calendarp@p=1 -POSTHOOK: Lineage: calendarp PARTITION(p=1).year EXPRESSION [(values__tmp__table__4)values__tmp__table__4.FieldSchema(name:tmp_values_col1, type:string, comment:), ] +POSTHOOK: Lineage: calendarp PARTITION(p=1).year SCRIPT [] PREHOOK: query: desc formatted calendarp partition (p=1) PREHOOK: type: DESCTABLE PREHOOK: Input: default@calendarp http://git-wip-us.apache.org/repos/asf/hive/blob/7e64114d/ql/src/test/results/clientpositive/llap/column_names_with_leading_and_trailing_spaces.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/llap/column_names_with_leading_and_trailing_spaces.q.out b/ql/src/test/results/clientpositive/llap/column_names_with_leading_and_trailing_spaces.q.out index 2b87d50..b327bf8 100644 --- a/ql/src/test/results/clientpositive/llap/column_names_with_leading_and_trailing_spaces.q.out +++ b/ql/src/test/results/clientpositive/llap/column_names_with_leading_and_trailing_spaces.q.out @@ -62,13 +62,15 @@ comment from deserializer COLUMN_STATS_ACCURATE {\"BASIC_STATS\":\"true\",\"COLUMN_STATS\":{\" left\":\"true\",\" middle \":\"true\",\"right \":\"true\"}} PREHOOK: query: insert into space values ("1", "2", "3") PREHOOK: type: QUERY +PREHOOK: Input: _dummy_database@_dummy_table PREHOOK: Output: default@space POSTHOOK: query: insert into space values ("1", "2", "3") POSTHOOK: type: QUERY +POSTHOOK: Input: _dummy_database@_dummy_table POSTHOOK: Output: default@space -POSTHOOK: Lineage: space. left SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] -POSTHOOK: Lineage: space. middle SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] -POSTHOOK: Lineage: space.right SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col3, type:string, comment:), ] +POSTHOOK: Lineage: space. left SCRIPT [] +POSTHOOK: Lineage: space. middle SCRIPT [] +POSTHOOK: Lineage: space.right SCRIPT [] PREHOOK: query: desc formatted space ` left` PREHOOK: type: DESCTABLE PREHOOK: Input: default@space @@ -99,12 +101,14 @@ POSTHOOK: Input: default@space 1 2 3 PREHOOK: query: insert into space (` middle `) values("2") PREHOOK: type: QUERY +PREHOOK: Input: _dummy_database@_dummy_table PREHOOK: Output: default@space POSTHOOK: query: insert into space (` middle `) values("2") POSTHOOK: type: QUERY +POSTHOOK: Input: _dummy_database@_dummy_table POSTHOOK: Output: default@space POSTHOOK: Lineage: space. left SIMPLE [] -POSTHOOK: Lineage: space. middle SIMPLE [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col1, type:string, comment:), ] +POSTHOOK: Lineage: space. middle SCRIPT [] POSTHOOK: Lineage: space.right SIMPLE [] PREHOOK: query: select * from space order by ` left` PREHOOK: type: QUERY http://git-wip-us.apache.org/repos/asf/hive/blob/7e64114d/ql/src/test/results/clientpositive/llap/column_table_stats_orc.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/llap/column_table_stats_orc.q.out b/ql/src/test/results/clientpositive/llap/column_table_stats_orc.q.out index 56b376e..2c8e9ab 100644 --- a/ql/src/test/results/clientpositive/llap/column_table_stats_orc.q.out +++ b/ql/src/test/results/clientpositive/llap/column_table_stats_orc.q.out @@ -12,12 +12,14 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@s PREHOOK: query: insert into table s values ('1','2') PREHOOK: type: QUERY +PREHOOK: Input: _dummy_database@_dummy_table PREHOOK: Output: default@s POSTHOOK: query: insert into table s values ('1','2') POSTHOOK: type: QUERY +POSTHOOK: Input: _dummy_database@_dummy_table POSTHOOK: Output: default@s -POSTHOOK: Lineage: s.key SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] -POSTHOOK: Lineage: s.value SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] +POSTHOOK: Lineage: s.key SCRIPT [] +POSTHOOK: Lineage: s.value SCRIPT [] PREHOOK: query: desc formatted s PREHOOK: type: DESCTABLE PREHOOK: Input: default@s @@ -247,20 +249,24 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@spart PREHOOK: query: insert into table spart PARTITION (ds="2008-04-08", hr="12") values ('1','2') PREHOOK: type: QUERY +PREHOOK: Input: _dummy_database@_dummy_table PREHOOK: Output: default@spart@ds=2008-04-08/hr=12 POSTHOOK: query: insert into table spart PARTITION (ds="2008-04-08", hr="12") values ('1','2') POSTHOOK: type: QUERY +POSTHOOK: Input: _dummy_database@_dummy_table POSTHOOK: Output: default@spart@ds=2008-04-08/hr=12 -POSTHOOK: Lineage: spart PARTITION(ds=2008-04-08,hr=12).key SIMPLE [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col1, type:string, comment:), ] -POSTHOOK: Lineage: spart PARTITION(ds=2008-04-08,hr=12).value SIMPLE [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col2, type:string, comment:), ] +POSTHOOK: Lineage: spart PARTITION(ds=2008-04-08,hr=12).key SCRIPT [] +POSTHOOK: Lineage: spart PARTITION(ds=2008-04-08,hr=12).value SCRIPT [] PREHOOK: query: insert into table spart PARTITION (ds="2008-04-08", hr="11") values ('1','2') PREHOOK: type: QUERY +PREHOOK: Input: _dummy_database@_dummy_table PREHOOK: Output: default@spart@ds=2008-04-08/hr=11 POSTHOOK: query: insert into table spart PARTITION (ds="2008-04-08", hr="11") values ('1','2') POSTHOOK: type: QUERY +POSTHOOK: Input: _dummy_database@_dummy_table POSTHOOK: Output: default@spart@ds=2008-04-08/hr=11 -POSTHOOK: Lineage: spart PARTITION(ds=2008-04-08,hr=11).key SIMPLE [(values__tmp__table__3)values__tmp__table__3.FieldSchema(name:tmp_values_col1, type:string, comment:), ] -POSTHOOK: Lineage: spart PARTITION(ds=2008-04-08,hr=11).value SIMPLE [(values__tmp__table__3)values__tmp__table__3.FieldSchema(name:tmp_values_col2, type:string, comment:), ] +POSTHOOK: Lineage: spart PARTITION(ds=2008-04-08,hr=11).key SCRIPT [] +POSTHOOK: Lineage: spart PARTITION(ds=2008-04-08,hr=11).value SCRIPT [] PREHOOK: query: desc formatted spart PREHOOK: type: DESCTABLE PREHOOK: Input: default@spart @@ -641,20 +647,24 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@spart PREHOOK: query: insert into table spart PARTITION (ds="2008-04-08", hr="12") values ('1','2') PREHOOK: type: QUERY +PREHOOK: Input: _dummy_database@_dummy_table PREHOOK: Output: default@spart@ds=2008-04-08/hr=12 POSTHOOK: query: insert into table spart PARTITION (ds="2008-04-08", hr="12") values ('1','2') POSTHOOK: type: QUERY +POSTHOOK: Input: _dummy_database@_dummy_table POSTHOOK: Output: default@spart@ds=2008-04-08/hr=12 -POSTHOOK: Lineage: spart PARTITION(ds=2008-04-08,hr=12).key SIMPLE [(values__tmp__table__4)values__tmp__table__4.FieldSchema(name:tmp_values_col1, type:string, comment:), ] -POSTHOOK: Lineage: spart PARTITION(ds=2008-04-08,hr=12).value SIMPLE [(values__tmp__table__4)values__tmp__table__4.FieldSchema(name:tmp_values_col2, type:string, comment:), ] +POSTHOOK: Lineage: spart PARTITION(ds=2008-04-08,hr=12).key SCRIPT [] +POSTHOOK: Lineage: spart PARTITION(ds=2008-04-08,hr=12).value SCRIPT [] PREHOOK: query: insert into table spart PARTITION (ds="2008-04-08", hr="11") values ('1','2') PREHOOK: type: QUERY +PREHOOK: Input: _dummy_database@_dummy_table PREHOOK: Output: default@spart@ds=2008-04-08/hr=11 POSTHOOK: query: insert into table spart PARTITION (ds="2008-04-08", hr="11") values ('1','2') POSTHOOK: type: QUERY +POSTHOOK: Input: _dummy_database@_dummy_table POSTHOOK: Output: default@spart@ds=2008-04-08/hr=11 -POSTHOOK: Lineage: spart PARTITION(ds=2008-04-08,hr=11).key SIMPLE [(values__tmp__table__5)values__tmp__table__5.FieldSchema(name:tmp_values_col1, type:string, comment:), ] -POSTHOOK: Lineage: spart PARTITION(ds=2008-04-08,hr=11).value SIMPLE [(values__tmp__table__5)values__tmp__table__5.FieldSchema(name:tmp_values_col2, type:string, comment:), ] +POSTHOOK: Lineage: spart PARTITION(ds=2008-04-08,hr=11).key SCRIPT [] +POSTHOOK: Lineage: spart PARTITION(ds=2008-04-08,hr=11).value SCRIPT [] PREHOOK: query: desc formatted spart PREHOOK: type: DESCTABLE PREHOOK: Input: default@spart http://git-wip-us.apache.org/repos/asf/hive/blob/7e64114d/ql/src/test/results/clientpositive/llap/constprog_semijoin.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/llap/constprog_semijoin.q.out b/ql/src/test/results/clientpositive/llap/constprog_semijoin.q.out index 3be74ec..1568d38 100644 --- a/ql/src/test/results/clientpositive/llap/constprog_semijoin.q.out +++ b/ql/src/test/results/clientpositive/llap/constprog_semijoin.q.out @@ -8,14 +8,16 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@table1 PREHOOK: query: insert into table1 (id, val, val1, dimid) values (1, 't1val01', 'val101', 100), (2, 't1val02', 'val102', 200), (3, 't1val03', 'val103', 103), (3, 't1val01', 'val104', 100), (2, 't1val05', 'val105', 200), (3, 't1val01', 'val106', 103), (1, 't1val07', 'val107', 200), (2, 't1val01', 'val108', 200), (3, 't1val09', 'val109', 103), (4,'t1val01', 'val110', 200) PREHOOK: type: QUERY +PREHOOK: Input: _dummy_database@_dummy_table PREHOOK: Output: default@table1 POSTHOOK: query: insert into table1 (id, val, val1, dimid) values (1, 't1val01', 'val101', 100), (2, 't1val02', 'val102', 200), (3, 't1val03', 'val103', 103), (3, 't1val01', 'val104', 100), (2, 't1val05', 'val105', 200), (3, 't1val01', 'val106', 103), (1, 't1val07', 'val107', 200), (2, 't1val01', 'val108', 200), (3, 't1val09', 'val109', 103), (4,'t1val01', 'val110', 200) POSTHOOK: type: QUERY +POSTHOOK: Input: _dummy_database@_dummy_table POSTHOOK: Output: default@table1 -POSTHOOK: Lineage: table1.dimid EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col4, type:string, comment:), ] -POSTHOOK: Lineage: table1.id EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] -POSTHOOK: Lineage: table1.val SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] -POSTHOOK: Lineage: table1.val1 SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col3, type:string, comment:), ] +POSTHOOK: Lineage: table1.dimid SCRIPT [] +POSTHOOK: Lineage: table1.id SCRIPT [] +POSTHOOK: Lineage: table1.val SCRIPT [] +POSTHOOK: Lineage: table1.val1 SCRIPT [] PREHOOK: query: create table table2 (id int, val2 string) PREHOOK: type: CREATETABLE PREHOOK: Output: database:default @@ -26,12 +28,14 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@table2 PREHOOK: query: insert into table2 (id, val2) values (1, 't2val201'), (2, 't2val202'), (3, 't2val203') PREHOOK: type: QUERY +PREHOOK: Input: _dummy_database@_dummy_table PREHOOK: Output: default@table2 POSTHOOK: query: insert into table2 (id, val2) values (1, 't2val201'), (2, 't2val202'), (3, 't2val203') POSTHOOK: type: QUERY +POSTHOOK: Input: _dummy_database@_dummy_table POSTHOOK: Output: default@table2 -POSTHOOK: Lineage: table2.id EXPRESSION [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col1, type:string, comment:), ] -POSTHOOK: Lineage: table2.val2 SIMPLE [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col2, type:string, comment:), ] +POSTHOOK: Lineage: table2.id SCRIPT [] +POSTHOOK: Lineage: table2.val2 SCRIPT [] PREHOOK: query: create table table3 (id int) PREHOOK: type: CREATETABLE PREHOOK: Output: database:default @@ -42,11 +46,13 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@table3 PREHOOK: query: insert into table3 (id) values (100), (100), (101), (102), (103) PREHOOK: type: QUERY +PREHOOK: Input: _dummy_database@_dummy_table PREHOOK: Output: default@table3 POSTHOOK: query: insert into table3 (id) values (100), (100), (101), (102), (103) POSTHOOK: type: QUERY +POSTHOOK: Input: _dummy_database@_dummy_table POSTHOOK: Output: default@table3 -POSTHOOK: Lineage: table3.id EXPRESSION [(values__tmp__table__3)values__tmp__table__3.FieldSchema(name:tmp_values_col1, type:string, comment:), ] +POSTHOOK: Lineage: table3.id SCRIPT [] PREHOOK: query: explain select table1.id, table1.val, table1.val1 from table1 left semi join table3 on table1.dimid = table3.id where table1.val = 't1val01' PREHOOK: type: QUERY POSTHOOK: query: explain select table1.id, table1.val, table1.val1 from table1 left semi join table3 on table1.dimid = table3.id where table1.val = 't1val01' http://git-wip-us.apache.org/repos/asf/hive/blob/7e64114d/ql/src/test/results/clientpositive/llap/cte_5.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/llap/cte_5.q.out b/ql/src/test/results/clientpositive/llap/cte_5.q.out index e7c10aa..17a86d3 100644 --- a/ql/src/test/results/clientpositive/llap/cte_5.q.out +++ b/ql/src/test/results/clientpositive/llap/cte_5.q.out @@ -20,12 +20,14 @@ POSTHOOK: Output: database:mydb POSTHOOK: Output: mydb@q1 PREHOOK: query: insert into q1 values (5, 'A') PREHOOK: type: QUERY +PREHOOK: Input: _dummy_database@_dummy_table PREHOOK: Output: mydb@q1 POSTHOOK: query: insert into q1 values (5, 'A') POSTHOOK: type: QUERY +POSTHOOK: Input: _dummy_database@_dummy_table POSTHOOK: Output: mydb@q1 -POSTHOOK: Lineage: q1.colnum EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] -POSTHOOK: Lineage: q1.colstring SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] +POSTHOOK: Lineage: q1.colnum SCRIPT [] +POSTHOOK: Lineage: q1.colstring SCRIPT [] PREHOOK: query: use default PREHOOK: type: SWITCHDATABASE PREHOOK: Input: database:default @@ -39,7 +41,6 @@ POSTHOOK: query: show tables in mydb POSTHOOK: type: SHOWTABLES POSTHOOK: Input: database:mydb q1 -values__tmp__table__1 PREHOOK: query: show tables PREHOOK: type: SHOWTABLES PREHOOK: Input: database:default http://git-wip-us.apache.org/repos/asf/hive/blob/7e64114d/ql/src/test/results/clientpositive/llap/cte_mat_4.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/llap/cte_mat_4.q.out b/ql/src/test/results/clientpositive/llap/cte_mat_4.q.out index 930a010..f3947ca 100644 --- a/ql/src/test/results/clientpositive/llap/cte_mat_4.q.out +++ b/ql/src/test/results/clientpositive/llap/cte_mat_4.q.out @@ -8,12 +8,14 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@q1 PREHOOK: query: insert into q1 values (1, 'A') PREHOOK: type: QUERY +PREHOOK: Input: _dummy_database@_dummy_table PREHOOK: Output: default@q1 POSTHOOK: query: insert into q1 values (1, 'A') POSTHOOK: type: QUERY +POSTHOOK: Input: _dummy_database@_dummy_table POSTHOOK: Output: default@q1 -POSTHOOK: Lineage: q1.a EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] -POSTHOOK: Lineage: q1.b SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] +POSTHOOK: Lineage: q1.a SCRIPT [] +POSTHOOK: Lineage: q1.b SCRIPT [] PREHOOK: query: show tables PREHOOK: type: SHOWTABLES PREHOOK: Input: database:default @@ -37,7 +39,6 @@ src_thrift srcbucket srcbucket2 srcpart -values__tmp__table__1 PREHOOK: query: explain with q1 as (select * from src where key= '5') select a.key @@ -149,7 +150,6 @@ src_thrift srcbucket srcbucket2 srcpart -values__tmp__table__1 PREHOOK: query: select * from q1 PREHOOK: type: QUERY PREHOOK: Input: default@q1 @@ -189,7 +189,6 @@ src_thrift srcbucket srcbucket2 srcpart -values__tmp__table__1 PREHOOK: query: explain with q1 as (select * from src where key= '5') select a.key @@ -300,4 +299,3 @@ src_thrift srcbucket srcbucket2 srcpart -values__tmp__table__1 http://git-wip-us.apache.org/repos/asf/hive/blob/7e64114d/ql/src/test/results/clientpositive/llap/cte_mat_5.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/llap/cte_mat_5.q.out b/ql/src/test/results/clientpositive/llap/cte_mat_5.q.out index 84b5ce3..ccf73ac 100644 --- a/ql/src/test/results/clientpositive/llap/cte_mat_5.q.out +++ b/ql/src/test/results/clientpositive/llap/cte_mat_5.q.out @@ -20,12 +20,14 @@ POSTHOOK: Output: database:mydb POSTHOOK: Output: mydb@q1 PREHOOK: query: insert into q1 values (5, 'A') PREHOOK: type: QUERY +PREHOOK: Input: _dummy_database@_dummy_table PREHOOK: Output: mydb@q1 POSTHOOK: query: insert into q1 values (5, 'A') POSTHOOK: type: QUERY +POSTHOOK: Input: _dummy_database@_dummy_table POSTHOOK: Output: mydb@q1 -POSTHOOK: Lineage: q1.colnum EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] -POSTHOOK: Lineage: q1.colstring SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] +POSTHOOK: Lineage: q1.colnum SCRIPT [] +POSTHOOK: Lineage: q1.colstring SCRIPT [] PREHOOK: query: use default PREHOOK: type: SWITCHDATABASE PREHOOK: Input: database:default @@ -39,7 +41,6 @@ POSTHOOK: query: show tables in mydb POSTHOOK: type: SHOWTABLES POSTHOOK: Input: database:mydb q1 -values__tmp__table__1 PREHOOK: query: show tables PREHOOK: type: SHOWTABLES PREHOOK: Input: database:default http://git-wip-us.apache.org/repos/asf/hive/blob/7e64114d/ql/src/test/results/clientpositive/llap/deleteAnalyze.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/llap/deleteAnalyze.q.out b/ql/src/test/results/clientpositive/llap/deleteAnalyze.q.out index 253d5b7..aeca518 100644 --- a/ql/src/test/results/clientpositive/llap/deleteAnalyze.q.out +++ b/ql/src/test/results/clientpositive/llap/deleteAnalyze.q.out @@ -20,14 +20,16 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@testdeci2 PREHOOK: query: insert into table testdeci2 values(1,12.123,12345.123,'desk1'),(2,123.123,1234.123,'desk2') PREHOOK: type: QUERY +PREHOOK: Input: _dummy_database@_dummy_table PREHOOK: Output: default@testdeci2 POSTHOOK: query: insert into table testdeci2 values(1,12.123,12345.123,'desk1'),(2,123.123,1234.123,'desk2') POSTHOOK: type: QUERY +POSTHOOK: Input: _dummy_database@_dummy_table POSTHOOK: Output: default@testdeci2 -POSTHOOK: Lineage: testdeci2.amount EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] -POSTHOOK: Lineage: testdeci2.id EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] -POSTHOOK: Lineage: testdeci2.item SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col4, type:string, comment:), ] -POSTHOOK: Lineage: testdeci2.sales_tax EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col3, type:string, comment:), ] +POSTHOOK: Lineage: testdeci2.amount SCRIPT [] +POSTHOOK: Lineage: testdeci2.id SCRIPT [] +POSTHOOK: Lineage: testdeci2.item SCRIPT [] +POSTHOOK: Lineage: testdeci2.sales_tax SCRIPT [] PREHOOK: query: describe formatted testdeci2 PREHOOK: type: DESCTABLE PREHOOK: Input: default@testdeci2 http://git-wip-us.apache.org/repos/asf/hive/blob/7e64114d/ql/src/test/results/clientpositive/llap/dynamic_semijoin_reduction_3.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/llap/dynamic_semijoin_reduction_3.q.out b/ql/src/test/results/clientpositive/llap/dynamic_semijoin_reduction_3.q.out index 91557e8..aca6b21 100644 --- a/ql/src/test/results/clientpositive/llap/dynamic_semijoin_reduction_3.q.out +++ b/ql/src/test/results/clientpositive/llap/dynamic_semijoin_reduction_3.q.out @@ -990,19 +990,21 @@ PREHOOK: query: insert into customer values ( 2, "DEF", "Def Co.", "PA", true, null ), ( 3, "XYZ", "Xyz Co.", "CA", true, null ) PREHOOK: type: QUERY +PREHOOK: Input: _dummy_database@_dummy_table PREHOOK: Output: type2_scd_helper@customer POSTHOOK: query: insert into customer values ( 1, "ABC", "Abc Co.", "OH", true, null ), ( 2, "DEF", "Def Co.", "PA", true, null ), ( 3, "XYZ", "Xyz Co.", "CA", true, null ) POSTHOOK: type: QUERY +POSTHOOK: Input: _dummy_database@_dummy_table POSTHOOK: Output: type2_scd_helper@customer -POSTHOOK: Lineage: customer.end_date EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col6, type:string, comment:), ] -POSTHOOK: Lineage: customer.is_current EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col5, type:string, comment:), ] -POSTHOOK: Lineage: customer.name SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col3, type:string, comment:), ] -POSTHOOK: Lineage: customer.sk SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] -POSTHOOK: Lineage: customer.source_pk EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] -POSTHOOK: Lineage: customer.state SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col4, type:string, comment:), ] +POSTHOOK: Lineage: customer.end_date EXPRESSION [] +POSTHOOK: Lineage: customer.is_current SCRIPT [] +POSTHOOK: Lineage: customer.name SCRIPT [] +POSTHOOK: Lineage: customer.sk SCRIPT [] +POSTHOOK: Lineage: customer.source_pk SCRIPT [] +POSTHOOK: Lineage: customer.state SCRIPT [] PREHOOK: query: select * from customer order by source_pk PREHOOK: type: QUERY PREHOOK: Input: type2_scd_helper@customer @@ -1036,6 +1038,7 @@ PREHOOK: query: insert into new_customer_stage values ( 3, "Xyz Co.", "TX" ), ( 4, "Pdq Co.", "WI" ) PREHOOK: type: QUERY +PREHOOK: Input: _dummy_database@_dummy_table PREHOOK: Output: type2_scd_helper@new_customer_stage POSTHOOK: query: insert into new_customer_stage values ( 1, "Abc Co.", "OH" ), @@ -1043,10 +1046,11 @@ POSTHOOK: query: insert into new_customer_stage values ( 3, "Xyz Co.", "TX" ), ( 4, "Pdq Co.", "WI" ) POSTHOOK: type: QUERY +POSTHOOK: Input: _dummy_database@_dummy_table POSTHOOK: Output: type2_scd_helper@new_customer_stage -POSTHOOK: Lineage: new_customer_stage.name SIMPLE [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col2, type:string, comment:), ] -POSTHOOK: Lineage: new_customer_stage.source_pk EXPRESSION [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col1, type:string, comment:), ] -POSTHOOK: Lineage: new_customer_stage.state SIMPLE [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col3, type:string, comment:), ] +POSTHOOK: Lineage: new_customer_stage.name SCRIPT [] +POSTHOOK: Lineage: new_customer_stage.source_pk SCRIPT [] +POSTHOOK: Lineage: new_customer_stage.state SCRIPT [] PREHOOK: query: drop table if exists scd_types PREHOOK: type: DROPTABLE POSTHOOK: query: drop table if exists scd_types @@ -1067,12 +1071,14 @@ POSTHOOK: Output: database:type2_scd_helper POSTHOOK: Output: type2_scd_helper@scd_types PREHOOK: query: insert into scd_types values (1, null), (2, -1), (2, null) PREHOOK: type: QUERY +PREHOOK: Input: _dummy_database@_dummy_table PREHOOK: Output: type2_scd_helper@scd_types POSTHOOK: query: insert into scd_types values (1, null), (2, -1), (2, null) POSTHOOK: type: QUERY +POSTHOOK: Input: _dummy_database@_dummy_table POSTHOOK: Output: type2_scd_helper@scd_types -POSTHOOK: Lineage: scd_types.invalid_key EXPRESSION [(values__tmp__table__3)values__tmp__table__3.FieldSchema(name:tmp_values_col2, type:string, comment:), ] -POSTHOOK: Lineage: scd_types.type EXPRESSION [(values__tmp__table__3)values__tmp__table__3.FieldSchema(name:tmp_values_col1, type:string, comment:), ] +POSTHOOK: Lineage: scd_types.invalid_key SCRIPT [] +POSTHOOK: Lineage: scd_types.type SCRIPT [] PREHOOK: query: merge into customer using ( select http://git-wip-us.apache.org/repos/asf/hive/blob/7e64114d/ql/src/test/results/clientpositive/llap/dynpart_sort_optimization_acid.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/llap/dynpart_sort_optimization_acid.q.out b/ql/src/test/results/clientpositive/llap/dynpart_sort_optimization_acid.q.out index e206e2b..7498485 100644 --- a/ql/src/test/results/clientpositive/llap/dynpart_sort_optimization_acid.q.out +++ b/ql/src/test/results/clientpositive/llap/dynpart_sort_optimization_acid.q.out @@ -53,12 +53,14 @@ POSTHOOK: Input: default@acid_part@ds=2008-04-08 1000 PREHOOK: query: insert into table acid_part partition(ds='2008-04-08') values("foo", "bar") PREHOOK: type: QUERY +PREHOOK: Input: _dummy_database@_dummy_table PREHOOK: Output: default@acid_part@ds=2008-04-08 POSTHOOK: query: insert into table acid_part partition(ds='2008-04-08') values("foo", "bar") POSTHOOK: type: QUERY +POSTHOOK: Input: _dummy_database@_dummy_table POSTHOOK: Output: default@acid_part@ds=2008-04-08 -POSTHOOK: Lineage: acid_part PARTITION(ds=2008-04-08).key SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] -POSTHOOK: Lineage: acid_part PARTITION(ds=2008-04-08).value SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] +POSTHOOK: Lineage: acid_part PARTITION(ds=2008-04-08).key SCRIPT [] +POSTHOOK: Lineage: acid_part PARTITION(ds=2008-04-08).value SCRIPT [] PREHOOK: query: select count(*) from acid_part where ds='2008-04-08' PREHOOK: type: QUERY PREHOOK: Input: default@acid_part @@ -337,12 +339,14 @@ POSTHOOK: Input: default@acid_part_sdpo@ds=2008-04-08 1000 PREHOOK: query: insert into table acid_part_sdpo partition(ds='2008-04-08') values("foo", "bar") PREHOOK: type: QUERY +PREHOOK: Input: _dummy_database@_dummy_table PREHOOK: Output: default@acid_part_sdpo@ds=2008-04-08 POSTHOOK: query: insert into table acid_part_sdpo partition(ds='2008-04-08') values("foo", "bar") POSTHOOK: type: QUERY +POSTHOOK: Input: _dummy_database@_dummy_table POSTHOOK: Output: default@acid_part_sdpo@ds=2008-04-08 -POSTHOOK: Lineage: acid_part_sdpo PARTITION(ds=2008-04-08).key SIMPLE [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col1, type:string, comment:), ] -POSTHOOK: Lineage: acid_part_sdpo PARTITION(ds=2008-04-08).value SIMPLE [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col2, type:string, comment:), ] +POSTHOOK: Lineage: acid_part_sdpo PARTITION(ds=2008-04-08).key SCRIPT [] +POSTHOOK: Lineage: acid_part_sdpo PARTITION(ds=2008-04-08).value SCRIPT [] PREHOOK: query: select count(*) from acid_part_sdpo where ds='2008-04-08' PREHOOK: type: QUERY PREHOOK: Input: default@acid_part_sdpo @@ -630,12 +634,14 @@ POSTHOOK: Input: default@acid_2l_part@ds=2008-04-08/hr=11 500 PREHOOK: query: insert into table acid_2L_part partition(ds='2008-04-08',hr=11) values("foo", "bar") PREHOOK: type: QUERY +PREHOOK: Input: _dummy_database@_dummy_table PREHOOK: Output: default@acid_2l_part@ds=2008-04-08/hr=11 POSTHOOK: query: insert into table acid_2L_part partition(ds='2008-04-08',hr=11) values("foo", "bar") POSTHOOK: type: QUERY +POSTHOOK: Input: _dummy_database@_dummy_table POSTHOOK: Output: default@acid_2l_part@ds=2008-04-08/hr=11 -POSTHOOK: Lineage: acid_2l_part PARTITION(ds=2008-04-08,hr=11).key SIMPLE [(values__tmp__table__3)values__tmp__table__3.FieldSchema(name:tmp_values_col1, type:string, comment:), ] -POSTHOOK: Lineage: acid_2l_part PARTITION(ds=2008-04-08,hr=11).value SIMPLE [(values__tmp__table__3)values__tmp__table__3.FieldSchema(name:tmp_values_col2, type:string, comment:), ] +POSTHOOK: Lineage: acid_2l_part PARTITION(ds=2008-04-08,hr=11).key SCRIPT [] +POSTHOOK: Lineage: acid_2l_part PARTITION(ds=2008-04-08,hr=11).value SCRIPT [] PREHOOK: query: select count(*) from acid_2L_part where ds='2008-04-08' and hr=11 PREHOOK: type: QUERY PREHOOK: Input: default@acid_2l_part @@ -1048,12 +1054,14 @@ POSTHOOK: Input: default@acid_2l_part_sdpo@ds=2008-04-08/hr=11 500 PREHOOK: query: insert into table acid_2L_part_sdpo partition(ds='2008-04-08',hr=11) values("foo", "bar") PREHOOK: type: QUERY +PREHOOK: Input: _dummy_database@_dummy_table PREHOOK: Output: default@acid_2l_part_sdpo@ds=2008-04-08/hr=11 POSTHOOK: query: insert into table acid_2L_part_sdpo partition(ds='2008-04-08',hr=11) values("foo", "bar") POSTHOOK: type: QUERY +POSTHOOK: Input: _dummy_database@_dummy_table POSTHOOK: Output: default@acid_2l_part_sdpo@ds=2008-04-08/hr=11 -POSTHOOK: Lineage: acid_2l_part_sdpo PARTITION(ds=2008-04-08,hr=11).key SIMPLE [(values__tmp__table__4)values__tmp__table__4.FieldSchema(name:tmp_values_col1, type:string, comment:), ] -POSTHOOK: Lineage: acid_2l_part_sdpo PARTITION(ds=2008-04-08,hr=11).value SIMPLE [(values__tmp__table__4)values__tmp__table__4.FieldSchema(name:tmp_values_col2, type:string, comment:), ] +POSTHOOK: Lineage: acid_2l_part_sdpo PARTITION(ds=2008-04-08,hr=11).key SCRIPT [] +POSTHOOK: Lineage: acid_2l_part_sdpo PARTITION(ds=2008-04-08,hr=11).value SCRIPT [] PREHOOK: query: select count(*) from acid_2L_part_sdpo where ds='2008-04-08' and hr=11 PREHOOK: type: QUERY PREHOOK: Input: default@acid_2l_part_sdpo @@ -1466,12 +1474,14 @@ POSTHOOK: Input: default@acid_2l_part_sdpo_no_cp@ds=2008-04-08/hr=11 500 PREHOOK: query: insert into table acid_2L_part_sdpo_no_cp partition(ds='2008-04-08',hr=11) values("foo", "bar") PREHOOK: type: QUERY +PREHOOK: Input: _dummy_database@_dummy_table PREHOOK: Output: default@acid_2l_part_sdpo_no_cp@ds=2008-04-08/hr=11 POSTHOOK: query: insert into table acid_2L_part_sdpo_no_cp partition(ds='2008-04-08',hr=11) values("foo", "bar") POSTHOOK: type: QUERY +POSTHOOK: Input: _dummy_database@_dummy_table POSTHOOK: Output: default@acid_2l_part_sdpo_no_cp@ds=2008-04-08/hr=11 -POSTHOOK: Lineage: acid_2l_part_sdpo_no_cp PARTITION(ds=2008-04-08,hr=11).key SIMPLE [(values__tmp__table__5)values__tmp__table__5.FieldSchema(name:tmp_values_col1, type:string, comment:), ] -POSTHOOK: Lineage: acid_2l_part_sdpo_no_cp PARTITION(ds=2008-04-08,hr=11).value SIMPLE [(values__tmp__table__5)values__tmp__table__5.FieldSchema(name:tmp_values_col2, type:string, comment:), ] +POSTHOOK: Lineage: acid_2l_part_sdpo_no_cp PARTITION(ds=2008-04-08,hr=11).key SCRIPT [] +POSTHOOK: Lineage: acid_2l_part_sdpo_no_cp PARTITION(ds=2008-04-08,hr=11).value SCRIPT [] PREHOOK: query: select count(*) from acid_2L_part_sdpo_no_cp where ds='2008-04-08' and hr=11 PREHOOK: type: QUERY PREHOOK: Input: default@acid_2l_part_sdpo_no_cp http://git-wip-us.apache.org/repos/asf/hive/blob/7e64114d/ql/src/test/results/clientpositive/llap/except_distinct.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/llap/except_distinct.q.out b/ql/src/test/results/clientpositive/llap/except_distinct.q.out index 59839e0..20dbcc4 100644 --- a/ql/src/test/results/clientpositive/llap/except_distinct.q.out +++ b/ql/src/test/results/clientpositive/llap/except_distinct.q.out @@ -8,11 +8,13 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@a PREHOOK: query: insert into table a values (0),(1),(2),(2),(2),(2),(3),(NULL),(NULL) PREHOOK: type: QUERY +PREHOOK: Input: _dummy_database@_dummy_table PREHOOK: Output: default@a POSTHOOK: query: insert into table a values (0),(1),(2),(2),(2),(2),(3),(NULL),(NULL) POSTHOOK: type: QUERY +POSTHOOK: Input: _dummy_database@_dummy_table POSTHOOK: Output: default@a -POSTHOOK: Lineage: a.key EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] +POSTHOOK: Lineage: a.key SCRIPT [] PREHOOK: query: create table b(key bigint) PREHOOK: type: CREATETABLE PREHOOK: Output: database:default @@ -23,11 +25,13 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@b PREHOOK: query: insert into table b values (1),(2),(2),(3),(5),(5),(NULL),(NULL),(NULL) PREHOOK: type: QUERY +PREHOOK: Input: _dummy_database@_dummy_table PREHOOK: Output: default@b POSTHOOK: query: insert into table b values (1),(2),(2),(3),(5),(5),(NULL),(NULL),(NULL) POSTHOOK: type: QUERY +POSTHOOK: Input: _dummy_database@_dummy_table POSTHOOK: Output: default@b -POSTHOOK: Lineage: b.key EXPRESSION [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col1, type:string, comment:), ] +POSTHOOK: Lineage: b.key SCRIPT [] PREHOOK: query: select * from a except distinct select * from b PREHOOK: type: QUERY PREHOOK: Input: default@a @@ -65,12 +69,14 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@a PREHOOK: query: insert into table a values (1,2),(1,2),(1,3),(2,3),(2,2) PREHOOK: type: QUERY +PREHOOK: Input: _dummy_database@_dummy_table PREHOOK: Output: default@a POSTHOOK: query: insert into table a values (1,2),(1,2),(1,3),(2,3),(2,2) POSTHOOK: type: QUERY +POSTHOOK: Input: _dummy_database@_dummy_table POSTHOOK: Output: default@a -POSTHOOK: Lineage: a.key EXPRESSION [(values__tmp__table__3)values__tmp__table__3.FieldSchema(name:tmp_values_col1, type:string, comment:), ] -POSTHOOK: Lineage: a.value EXPRESSION [(values__tmp__table__3)values__tmp__table__3.FieldSchema(name:tmp_values_col2, type:string, comment:), ] +POSTHOOK: Lineage: a.key SCRIPT [] +POSTHOOK: Lineage: a.value SCRIPT [] PREHOOK: query: create table b(key int, value int) PREHOOK: type: CREATETABLE PREHOOK: Output: database:default @@ -81,12 +87,14 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@b PREHOOK: query: insert into table b values (1,2),(2,3),(2,2),(2,2),(2,20) PREHOOK: type: QUERY +PREHOOK: Input: _dummy_database@_dummy_table PREHOOK: Output: default@b POSTHOOK: query: insert into table b values (1,2),(2,3),(2,2),(2,2),(2,20) POSTHOOK: type: QUERY +POSTHOOK: Input: _dummy_database@_dummy_table POSTHOOK: Output: default@b -POSTHOOK: Lineage: b.key EXPRESSION [(values__tmp__table__4)values__tmp__table__4.FieldSchema(name:tmp_values_col1, type:string, comment:), ] -POSTHOOK: Lineage: b.value EXPRESSION [(values__tmp__table__4)values__tmp__table__4.FieldSchema(name:tmp_values_col2, type:string, comment:), ] +POSTHOOK: Lineage: b.key SCRIPT [] +POSTHOOK: Lineage: b.value SCRIPT [] PREHOOK: query: select * from a except distinct select * from b PREHOOK: type: QUERY PREHOOK: Input: default@a http://git-wip-us.apache.org/repos/asf/hive/blob/7e64114d/ql/src/test/results/clientpositive/llap/groupby_rollup_empty.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/llap/groupby_rollup_empty.q.out b/ql/src/test/results/clientpositive/llap/groupby_rollup_empty.q.out index 061b0d7..3a2d438 100644 --- a/ql/src/test/results/clientpositive/llap/groupby_rollup_empty.q.out +++ b/ql/src/test/results/clientpositive/llap/groupby_rollup_empty.q.out @@ -65,13 +65,15 @@ POSTHOOK: Input: default@tx1 NULL 1 NULL,1 PREHOOK: query: insert into tx1 values (1,1,1) PREHOOK: type: QUERY +PREHOOK: Input: _dummy_database@_dummy_table PREHOOK: Output: default@tx1 POSTHOOK: query: insert into tx1 values (1,1,1) POSTHOOK: type: QUERY +POSTHOOK: Input: _dummy_database@_dummy_table POSTHOOK: Output: default@tx1 -POSTHOOK: Lineage: tx1.a EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] -POSTHOOK: Lineage: tx1.b EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] -POSTHOOK: Lineage: tx1.c EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col3, type:string, comment:), ] +POSTHOOK: Lineage: tx1.a SCRIPT [] +POSTHOOK: Lineage: tx1.b SCRIPT [] +POSTHOOK: Lineage: tx1.c SCRIPT [] PREHOOK: query: select sum(c), grouping(b), 'NULL,1' as expected http://git-wip-us.apache.org/repos/asf/hive/blob/7e64114d/ql/src/test/results/clientpositive/llap/insert_into1.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/llap/insert_into1.q.out b/ql/src/test/results/clientpositive/llap/insert_into1.q.out index ae0b2a3..5cc9b1d 100644 --- a/ql/src/test/results/clientpositive/llap/insert_into1.q.out +++ b/ql/src/test/results/clientpositive/llap/insert_into1.q.out @@ -700,20 +700,28 @@ STAGE PLANS: Map 1 Map Operator Tree: TableScan - alias: values__tmp__table__1 - Statistics: Num rows: 1 Data size: 368 Basic stats: COMPLETE Column stats: NONE + alias: _dummy_table + Row Limit Per Split: 1 + Statistics: Num rows: 1 Data size: 10 Basic stats: COMPLETE Column stats: COMPLETE Select Operator - expressions: UDFToInteger(tmp_values_col1) (type: int), tmp_values_col2 (type: string) - outputColumnNames: _col0, _col1 - Statistics: Num rows: 1 Data size: 368 Basic stats: COMPLETE Column stats: NONE - File Output Operator - compressed: false - Statistics: Num rows: 1 Data size: 368 Basic stats: COMPLETE Column stats: NONE - table: - input format: org.apache.hadoop.mapred.TextInputFormat - output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat - serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe - name: default.insert_into1 + expressions: array(const struct(1,'abc')) (type: array<struct<col1:int,col2:string>>) + outputColumnNames: _col0 + Statistics: Num rows: 1 Data size: 48 Basic stats: COMPLETE Column stats: COMPLETE + UDTF Operator + Statistics: Num rows: 1 Data size: 48 Basic stats: COMPLETE Column stats: COMPLETE + function name: inline + Select Operator + expressions: col1 (type: int), col2 (type: string) + outputColumnNames: _col0, _col1 + Statistics: Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: COMPLETE + File Output Operator + compressed: false + Statistics: Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: COMPLETE + table: + input format: org.apache.hadoop.mapred.TextInputFormat + output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat + serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe + name: default.insert_into1 Execution mode: llap LLAP IO: no inputs @@ -732,12 +740,14 @@ STAGE PLANS: PREHOOK: query: insert into table insert_into1 values(1, 'abc') PREHOOK: type: QUERY +PREHOOK: Input: _dummy_database@_dummy_table PREHOOK: Output: default@insert_into1 POSTHOOK: query: insert into table insert_into1 values(1, 'abc') POSTHOOK: type: QUERY +POSTHOOK: Input: _dummy_database@_dummy_table POSTHOOK: Output: default@insert_into1 -POSTHOOK: Lineage: insert_into1.key EXPRESSION [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col1, type:string, comment:), ] -POSTHOOK: Lineage: insert_into1.value SIMPLE [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col2, type:string, comment:), ] +POSTHOOK: Lineage: insert_into1.key SCRIPT [] +POSTHOOK: Lineage: insert_into1.value SCRIPT [] PREHOOK: query: explain SELECT COUNT(*) FROM insert_into1 PREHOOK: type: QUERY http://git-wip-us.apache.org/repos/asf/hive/blob/7e64114d/ql/src/test/results/clientpositive/llap/insert_into2.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/llap/insert_into2.q.out b/ql/src/test/results/clientpositive/llap/insert_into2.q.out index 83f0e3d..3fb0d64 100644 --- a/ql/src/test/results/clientpositive/llap/insert_into2.q.out +++ b/ql/src/test/results/clientpositive/llap/insert_into2.q.out @@ -564,12 +564,14 @@ POSTHOOK: Input: default@insert_into2 50 PREHOOK: query: insert into table insert_into2 partition (ds='2') values(1, 'abc') PREHOOK: type: QUERY +PREHOOK: Input: _dummy_database@_dummy_table PREHOOK: Output: default@insert_into2@ds=2 POSTHOOK: query: insert into table insert_into2 partition (ds='2') values(1, 'abc') POSTHOOK: type: QUERY +POSTHOOK: Input: _dummy_database@_dummy_table POSTHOOK: Output: default@insert_into2@ds=2 -POSTHOOK: Lineage: insert_into2 PARTITION(ds=2).key EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] -POSTHOOK: Lineage: insert_into2 PARTITION(ds=2).value SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] +POSTHOOK: Lineage: insert_into2 PARTITION(ds=2).key SCRIPT [] +POSTHOOK: Lineage: insert_into2 PARTITION(ds=2).value SCRIPT [] PREHOOK: query: explain SELECT COUNT(*) FROM insert_into2 where ds='2' PREHOOK: type: QUERY