Repository: hive Updated Branches: refs/heads/master 588c3911a -> c7ac34056
http://git-wip-us.apache.org/repos/asf/hive/blob/c7ac3405/ql/src/test/results/clientpositive/llap/vectorized_ptf.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/llap/vectorized_ptf.q.out b/ql/src/test/results/clientpositive/llap/vectorized_ptf.q.out index 695262e..b40acf9 100644 --- a/ql/src/test/results/clientpositive/llap/vectorized_ptf.q.out +++ b/ql/src/test/results/clientpositive/llap/vectorized_ptf.q.out @@ -4177,6 +4177,9 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: default@part_orc POSTHOOK: Output: database:default POSTHOOK: Output: default@mfgr_price_view +POSTHOOK: Lineage: mfgr_price_view.p_brand SIMPLE [(part_orc)part_orc.FieldSchema(name:p_brand, type:string, comment:null), ] +POSTHOOK: Lineage: mfgr_price_view.p_mfgr SIMPLE [(part_orc)part_orc.FieldSchema(name:p_mfgr, type:string, comment:null), ] +POSTHOOK: Lineage: mfgr_price_view.s EXPRESSION [(part_orc)part_orc.FieldSchema(name:p_retailprice, type:double, comment:null), ] PREHOOK: query: explain extended select p_mfgr, p_brand, s, round(sum(s) over w1,2) as s1 http://git-wip-us.apache.org/repos/asf/hive/blob/c7ac3405/ql/src/test/results/clientpositive/llap/windowing.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/llap/windowing.q.out b/ql/src/test/results/clientpositive/llap/windowing.q.out index 61c5591..86804f2 100644 --- a/ql/src/test/results/clientpositive/llap/windowing.q.out +++ b/ql/src/test/results/clientpositive/llap/windowing.q.out @@ -950,6 +950,9 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: default@part POSTHOOK: Output: database:default POSTHOOK: Output: default@mfgr_price_view +POSTHOOK: Lineage: mfgr_price_view.p_brand SIMPLE [(part)part.FieldSchema(name:p_brand, type:string, comment:null), ] +POSTHOOK: Lineage: mfgr_price_view.p_mfgr SIMPLE [(part)part.FieldSchema(name:p_mfgr, type:string, comment:null), ] +POSTHOOK: Lineage: mfgr_price_view.s EXPRESSION [(part)part.FieldSchema(name:p_retailprice, type:double, comment:null), ] PREHOOK: query: select * from ( select p_mfgr, p_brand, s, @@ -1040,6 +1043,9 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: default@part POSTHOOK: Output: database:default POSTHOOK: Output: default@mfgr_brand_price_view +POSTHOOK: Lineage: mfgr_brand_price_view.p_brand SIMPLE [(part)part.FieldSchema(name:p_brand, type:string, comment:null), ] +POSTHOOK: Lineage: mfgr_brand_price_view.p_mfgr SIMPLE [(part)part.FieldSchema(name:p_mfgr, type:string, comment:null), ] +POSTHOOK: Lineage: mfgr_brand_price_view.s SCRIPT [(part)part.FieldSchema(name:p_partkey, type:int, comment:null), (part)part.FieldSchema(name:p_name, type:string, comment:null), (part)part.FieldSchema(name:p_mfgr, type:string, comment:null), (part)part.FieldSchema(name:p_brand, type:string, comment:null), (part)part.FieldSchema(name:p_type, type:string, comment:null), (part)part.FieldSchema(name:p_size, type:int, comment:null), (part)part.FieldSchema(name:p_container, type:string, comment:null), (part)part.FieldSchema(name:p_retailprice, type:double, comment:null), (part)part.FieldSchema(name:p_comment, type:string, comment:null), ] PREHOOK: query: select * from mfgr_brand_price_view PREHOOK: type: QUERY PREHOOK: Input: default@mfgr_brand_price_view http://git-wip-us.apache.org/repos/asf/hive/blob/c7ac3405/ql/src/test/results/clientpositive/masking_2.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/masking_2.q.out b/ql/src/test/results/clientpositive/masking_2.q.out index 4900a5a..83fca41 100644 --- a/ql/src/test/results/clientpositive/masking_2.q.out +++ b/ql/src/test/results/clientpositive/masking_2.q.out @@ -8,6 +8,8 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: default@src POSTHOOK: Output: database:default POSTHOOK: Output: default@masking_test +POSTHOOK: Lineage: masking_test.key EXPRESSION [(src)src.FieldSchema(name:key, type:string, comment:default), ] +POSTHOOK: Lineage: masking_test.value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: explain select * from masking_test PREHOOK: type: QUERY POSTHOOK: query: explain select * from masking_test http://git-wip-us.apache.org/repos/asf/hive/blob/c7ac3405/ql/src/test/results/clientpositive/masking_6.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/masking_6.q.out b/ql/src/test/results/clientpositive/masking_6.q.out index 56e4006..b9004b9 100644 --- a/ql/src/test/results/clientpositive/masking_6.q.out +++ b/ql/src/test/results/clientpositive/masking_6.q.out @@ -12,6 +12,9 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: default@src POSTHOOK: Output: database:default POSTHOOK: Output: default@masking_test +POSTHOOK: Lineage: masking_test._c2 SIMPLE [] +POSTHOOK: Lineage: masking_test.key EXPRESSION [(src)src.FieldSchema(name:key, type:string, comment:default), ] +POSTHOOK: Lineage: masking_test.value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: explain select * from masking_test PREHOOK: type: QUERY POSTHOOK: query: explain select * from masking_test @@ -139,6 +142,18 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: default@src POSTHOOK: Output: database:default POSTHOOK: Output: default@masking_test +POSTHOOK: Lineage: masking_test._c1 SIMPLE [] +POSTHOOK: Lineage: masking_test._c10 SIMPLE [] +POSTHOOK: Lineage: masking_test._c11 SIMPLE [] +POSTHOOK: Lineage: masking_test._c2 SIMPLE [] +POSTHOOK: Lineage: masking_test._c3 SIMPLE [] +POSTHOOK: Lineage: masking_test._c4 SIMPLE [] +POSTHOOK: Lineage: masking_test._c5 SIMPLE [] +POSTHOOK: Lineage: masking_test._c6 SIMPLE [] +POSTHOOK: Lineage: masking_test._c7 SIMPLE [] +POSTHOOK: Lineage: masking_test._c8 SIMPLE [] +POSTHOOK: Lineage: masking_test._c9 SIMPLE [] +POSTHOOK: Lineage: masking_test.key EXPRESSION [(src)src.FieldSchema(name:key, type:string, comment:default), ] PREHOOK: query: explain select * from masking_test PREHOOK: type: QUERY POSTHOOK: query: explain select * from masking_test http://git-wip-us.apache.org/repos/asf/hive/blob/c7ac3405/ql/src/test/results/clientpositive/masking_7.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/masking_7.q.out b/ql/src/test/results/clientpositive/masking_7.q.out index c4531f8..691cd89 100644 --- a/ql/src/test/results/clientpositive/masking_7.q.out +++ b/ql/src/test/results/clientpositive/masking_7.q.out @@ -12,6 +12,10 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: default@src POSTHOOK: Output: database:default POSTHOOK: Output: default@masking_test +POSTHOOK: Lineage: masking_test._c2 SIMPLE [] +POSTHOOK: Lineage: masking_test.key EXPRESSION [(src)src.FieldSchema(name:key, type:string, comment:default), ] +POSTHOOK: Lineage: masking_test.row__id SIMPLE [(src)src.FieldSchema(name:ROW__ID, type:struct<transactionId:bigint,bucketId:int,rowId:bigint>, comment:), ] +POSTHOOK: Lineage: masking_test.value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: explain select * from masking_test PREHOOK: type: QUERY POSTHOOK: query: explain select * from masking_test @@ -139,6 +143,19 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: default@src POSTHOOK: Output: database:default POSTHOOK: Output: default@masking_test +POSTHOOK: Lineage: masking_test._c1 SIMPLE [] +POSTHOOK: Lineage: masking_test._c10 SIMPLE [] +POSTHOOK: Lineage: masking_test._c11 SIMPLE [] +POSTHOOK: Lineage: masking_test._c12 SIMPLE [] +POSTHOOK: Lineage: masking_test._c3 SIMPLE [] +POSTHOOK: Lineage: masking_test._c4 SIMPLE [] +POSTHOOK: Lineage: masking_test._c5 SIMPLE [] +POSTHOOK: Lineage: masking_test._c6 SIMPLE [] +POSTHOOK: Lineage: masking_test._c7 SIMPLE [] +POSTHOOK: Lineage: masking_test._c8 SIMPLE [] +POSTHOOK: Lineage: masking_test._c9 SIMPLE [] +POSTHOOK: Lineage: masking_test.key EXPRESSION [(src)src.FieldSchema(name:key, type:string, comment:default), ] +POSTHOOK: Lineage: masking_test.row__id SIMPLE [(src)src.FieldSchema(name:ROW__ID, type:struct<transactionId:bigint,bucketId:int,rowId:bigint>, comment:), ] PREHOOK: query: explain select * from masking_test PREHOOK: type: QUERY POSTHOOK: query: explain select * from masking_test http://git-wip-us.apache.org/repos/asf/hive/blob/c7ac3405/ql/src/test/results/clientpositive/masking_disablecbo_2.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/masking_disablecbo_2.q.out b/ql/src/test/results/clientpositive/masking_disablecbo_2.q.out index 48a366e..a9ace62 100644 --- a/ql/src/test/results/clientpositive/masking_disablecbo_2.q.out +++ b/ql/src/test/results/clientpositive/masking_disablecbo_2.q.out @@ -8,6 +8,8 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: default@src POSTHOOK: Output: database:default POSTHOOK: Output: default@masking_test +POSTHOOK: Lineage: masking_test.key EXPRESSION [(src)src.FieldSchema(name:key, type:string, comment:default), ] +POSTHOOK: Lineage: masking_test.value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: explain select * from masking_test PREHOOK: type: QUERY POSTHOOK: query: explain select * from masking_test http://git-wip-us.apache.org/repos/asf/hive/blob/c7ac3405/ql/src/test/results/clientpositive/ppd_field_garbage.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/ppd_field_garbage.q.out b/ql/src/test/results/clientpositive/ppd_field_garbage.q.out index 0dac980..3b9498c 100644 --- a/ql/src/test/results/clientpositive/ppd_field_garbage.q.out +++ b/ql/src/test/results/clientpositive/ppd_field_garbage.q.out @@ -16,6 +16,9 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: default@test_issue POSTHOOK: Output: database:default POSTHOOK: Output: default@v_test_issue +POSTHOOK: Lineage: v_test_issue.age EXPRESSION [(test_issue)test_issue.FieldSchema(name:test_c, type:struct<user_c:struct<age:int>>, comment:null), ] +POSTHOOK: Lineage: v_test_issue.fileid SIMPLE [(test_issue)test_issue.FieldSchema(name:fileid, type:int, comment:null), ] +POSTHOOK: Lineage: v_test_issue.u SCRIPT [(test_issue)test_issue.FieldSchema(name:infos, type:array<struct<u:int>>, comment:null), ] PREHOOK: query: LOAD DATA LOCAL INPATH '../../data/files/kv1.txt' INTO TABLE test_issue PREHOOK: type: LOAD #### A masked pattern was here #### http://git-wip-us.apache.org/repos/asf/hive/blob/c7ac3405/ql/src/test/results/clientpositive/quotedid_basic.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/quotedid_basic.q.out b/ql/src/test/results/clientpositive/quotedid_basic.q.out index 382c4ad..8897ae9 100644 --- a/ql/src/test/results/clientpositive/quotedid_basic.q.out +++ b/ql/src/test/results/clientpositive/quotedid_basic.q.out @@ -391,6 +391,8 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: default@t4 POSTHOOK: Output: database:default POSTHOOK: Output: default@v1 +POSTHOOK: Lineage: v1.x+1` SIMPLE [(t4)t4.FieldSchema(name:x+1`, type:string, comment:null), ] +POSTHOOK: Lineage: v1.y&y SIMPLE [(t4)t4.FieldSchema(name:y&y, type:string, comment:null), ] PREHOOK: query: select `x+1```, `y&y`, rank() over(partition by `x+1``` order by `y&y`) from v1 group by `x+1```, `y&y` http://git-wip-us.apache.org/repos/asf/hive/blob/c7ac3405/ql/src/test/results/clientpositive/show_create_table_view.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/show_create_table_view.q.out b/ql/src/test/results/clientpositive/show_create_table_view.q.out index a27209d..7756ef1 100644 --- a/ql/src/test/results/clientpositive/show_create_table_view.q.out +++ b/ql/src/test/results/clientpositive/show_create_table_view.q.out @@ -8,6 +8,8 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: default@src POSTHOOK: Output: database:default POSTHOOK: Output: default@tmp_copy_src +POSTHOOK: Lineage: tmp_copy_src.key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] +POSTHOOK: Lineage: tmp_copy_src.value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: SHOW CREATE TABLE tmp_copy_src PREHOOK: type: SHOW_CREATETABLE PREHOOK: Input: default@tmp_copy_src http://git-wip-us.apache.org/repos/asf/hive/blob/c7ac3405/ql/src/test/results/clientpositive/show_views.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/show_views.q.out b/ql/src/test/results/clientpositive/show_views.q.out index 723b334..41f1e65 100644 --- a/ql/src/test/results/clientpositive/show_views.q.out +++ b/ql/src/test/results/clientpositive/show_views.q.out @@ -34,6 +34,9 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: test1@shtb_test1 POSTHOOK: Output: database:test1 POSTHOOK: Output: test1@shtb_test1_view1 +POSTHOOK: Lineage: shtb_test1_view1.ds SIMPLE [(shtb_test1)shtb_test1.FieldSchema(name:ds, type:string, comment:null), ] +POSTHOOK: Lineage: shtb_test1_view1.key SIMPLE [(shtb_test1)shtb_test1.FieldSchema(name:key, type:int, comment:null), ] +POSTHOOK: Lineage: shtb_test1_view1.value SIMPLE [(shtb_test1)shtb_test1.FieldSchema(name:value, type:string, comment:null), ] PREHOOK: query: CREATE VIEW shtb_test1_view2 AS SELECT * FROM shtb_test1 where KEY > 100 and KEY < 200 PREHOOK: type: CREATEVIEW PREHOOK: Input: test1@shtb_test1 @@ -44,6 +47,9 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: test1@shtb_test1 POSTHOOK: Output: database:test1 POSTHOOK: Output: test1@shtb_test1_view2 +POSTHOOK: Lineage: shtb_test1_view2.ds SIMPLE [(shtb_test1)shtb_test1.FieldSchema(name:ds, type:string, comment:null), ] +POSTHOOK: Lineage: shtb_test1_view2.key SIMPLE [(shtb_test1)shtb_test1.FieldSchema(name:key, type:int, comment:null), ] +POSTHOOK: Lineage: shtb_test1_view2.value SIMPLE [(shtb_test1)shtb_test1.FieldSchema(name:value, type:string, comment:null), ] PREHOOK: query: CREATE VIEW shtb_full_view2 AS SELECT * FROM shtb_test1 PREHOOK: type: CREATEVIEW PREHOOK: Input: test1@shtb_test1 @@ -54,6 +60,9 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: test1@shtb_test1 POSTHOOK: Output: database:test1 POSTHOOK: Output: test1@shtb_full_view2 +POSTHOOK: Lineage: shtb_full_view2.ds SIMPLE [(shtb_test1)shtb_test1.FieldSchema(name:ds, type:string, comment:null), ] +POSTHOOK: Lineage: shtb_full_view2.key SIMPLE [(shtb_test1)shtb_test1.FieldSchema(name:key, type:int, comment:null), ] +POSTHOOK: Lineage: shtb_full_view2.value SIMPLE [(shtb_test1)shtb_test1.FieldSchema(name:value, type:string, comment:null), ] PREHOOK: query: USE test2 PREHOOK: type: SWITCHDATABASE PREHOOK: Input: database:test2 @@ -86,6 +95,9 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: test2@shtb_test1 POSTHOOK: Output: database:test2 POSTHOOK: Output: test2@shtb_test1_view1 +POSTHOOK: Lineage: shtb_test1_view1.ds SIMPLE [(shtb_test1)shtb_test1.FieldSchema(name:ds, type:string, comment:null), ] +POSTHOOK: Lineage: shtb_test1_view1.key SIMPLE [(shtb_test1)shtb_test1.FieldSchema(name:key, type:int, comment:null), ] +POSTHOOK: Lineage: shtb_test1_view1.value SIMPLE [(shtb_test1)shtb_test1.FieldSchema(name:value, type:string, comment:null), ] PREHOOK: query: CREATE VIEW shtb_test2_view2 AS SELECT * FROM shtb_test2 where KEY > 100 and KEY < 200 PREHOOK: type: CREATEVIEW PREHOOK: Input: test2@shtb_test2 @@ -96,6 +108,9 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: test2@shtb_test2 POSTHOOK: Output: database:test2 POSTHOOK: Output: test2@shtb_test2_view2 +POSTHOOK: Lineage: shtb_test2_view2.ds SIMPLE [(shtb_test2)shtb_test2.FieldSchema(name:ds, type:string, comment:null), ] +POSTHOOK: Lineage: shtb_test2_view2.key SIMPLE [(shtb_test2)shtb_test2.FieldSchema(name:key, type:int, comment:null), ] +POSTHOOK: Lineage: shtb_test2_view2.value SIMPLE [(shtb_test2)shtb_test2.FieldSchema(name:value, type:string, comment:null), ] PREHOOK: query: USE test1 PREHOOK: type: SWITCHDATABASE PREHOOK: Input: database:test1 @@ -203,6 +218,7 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: database@foo POSTHOOK: Output: database:database POSTHOOK: Output: database@fooview +POSTHOOK: Lineage: fooview.a SIMPLE [(foo)foo.FieldSchema(name:a, type:int, comment:null), ] PREHOOK: query: USE default PREHOOK: type: SWITCHDATABASE PREHOOK: Input: database:default http://git-wip-us.apache.org/repos/asf/hive/blob/c7ac3405/ql/src/test/results/clientpositive/spark/join_view.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/spark/join_view.q.out b/ql/src/test/results/clientpositive/spark/join_view.q.out index 6800218..61867f7 100644 --- a/ql/src/test/results/clientpositive/spark/join_view.q.out +++ b/ql/src/test/results/clientpositive/spark/join_view.q.out @@ -34,6 +34,9 @@ POSTHOOK: Input: default@invites POSTHOOK: Input: default@invites2 POSTHOOK: Output: database:default POSTHOOK: Output: default@v +POSTHOOK: Lineage: v.bar SIMPLE [(invites)invites.FieldSchema(name:bar, type:string, comment:null), ] +POSTHOOK: Lineage: v.ds SIMPLE [(invites2)invites2.FieldSchema(name:ds, type:string, comment:null), ] +POSTHOOK: Lineage: v.foo SIMPLE [(invites2)invites2.FieldSchema(name:foo, type:int, comment:null), ] Warning: Shuffle Join JOIN[8][tables = [$hdt$_0, $hdt$_1]] in Work 'Reducer 2' is a cross product PREHOOK: query: explain select * from v where ds='2011-09-01' PREHOOK: type: QUERY http://git-wip-us.apache.org/repos/asf/hive/blob/c7ac3405/ql/src/test/results/clientpositive/spark/ptf.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/spark/ptf.q.out b/ql/src/test/results/clientpositive/spark/ptf.q.out index 95d16b5..d7a7de0 100644 --- a/ql/src/test/results/clientpositive/spark/ptf.q.out +++ b/ql/src/test/results/clientpositive/spark/ptf.q.out @@ -2621,6 +2621,9 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: default@part POSTHOOK: Output: database:default POSTHOOK: Output: default@mfgr_price_view +POSTHOOK: Lineage: mfgr_price_view.p_brand SIMPLE [(part)part.FieldSchema(name:p_brand, type:string, comment:null), ] +POSTHOOK: Lineage: mfgr_price_view.p_mfgr SIMPLE [(part)part.FieldSchema(name:p_mfgr, type:string, comment:null), ] +POSTHOOK: Lineage: mfgr_price_view.s EXPRESSION [(part)part.FieldSchema(name:p_retailprice, type:double, comment:null), ] PREHOOK: query: explain select p_mfgr, p_brand, s, round(sum(s) over w1,2) as s1 http://git-wip-us.apache.org/repos/asf/hive/blob/c7ac3405/ql/src/test/results/clientpositive/spark/subquery_exists.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/spark/subquery_exists.q.out b/ql/src/test/results/clientpositive/spark/subquery_exists.q.out index fc76158..4c1560d 100644 --- a/ql/src/test/results/clientpositive/spark/subquery_exists.q.out +++ b/ql/src/test/results/clientpositive/spark/subquery_exists.q.out @@ -201,6 +201,8 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: default@src POSTHOOK: Output: database:default POSTHOOK: Output: default@cv1 +POSTHOOK: Lineage: cv1.key SIMPLE [(src)b.FieldSchema(name:key, type:string, comment:default), ] +POSTHOOK: Lineage: cv1.value SIMPLE [(src)b.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: select * from cv1 PREHOOK: type: QUERY PREHOOK: Input: default@cv1 http://git-wip-us.apache.org/repos/asf/hive/blob/c7ac3405/ql/src/test/results/clientpositive/spark/union_top_level.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/spark/union_top_level.q.out b/ql/src/test/results/clientpositive/spark/union_top_level.q.out index 0b4ed79..74719bb 100644 --- a/ql/src/test/results/clientpositive/spark/union_top_level.q.out +++ b/ql/src/test/results/clientpositive/spark/union_top_level.q.out @@ -1010,6 +1010,8 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: default@src POSTHOOK: Output: database:default POSTHOOK: Output: default@union_top_view +POSTHOOK: Lineage: union_top_view.key EXPRESSION [(src)src.FieldSchema(name:key, type:string, comment:default), ] +POSTHOOK: Lineage: union_top_view.value EXPRESSION [] PREHOOK: query: select * from union_top_view PREHOOK: type: QUERY PREHOOK: Input: default@src http://git-wip-us.apache.org/repos/asf/hive/blob/c7ac3405/ql/src/test/results/clientpositive/spark/vectorized_ptf.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/spark/vectorized_ptf.q.out b/ql/src/test/results/clientpositive/spark/vectorized_ptf.q.out index 71e4818..59d0acb 100644 --- a/ql/src/test/results/clientpositive/spark/vectorized_ptf.q.out +++ b/ql/src/test/results/clientpositive/spark/vectorized_ptf.q.out @@ -4106,6 +4106,9 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: default@part_orc POSTHOOK: Output: database:default POSTHOOK: Output: default@mfgr_price_view +POSTHOOK: Lineage: mfgr_price_view.p_brand SIMPLE [(part_orc)part_orc.FieldSchema(name:p_brand, type:string, comment:null), ] +POSTHOOK: Lineage: mfgr_price_view.p_mfgr SIMPLE [(part_orc)part_orc.FieldSchema(name:p_mfgr, type:string, comment:null), ] +POSTHOOK: Lineage: mfgr_price_view.s EXPRESSION [(part_orc)part_orc.FieldSchema(name:p_retailprice, type:double, comment:null), ] PREHOOK: query: explain extended select p_mfgr, p_brand, s, round(sum(s) over w1,2) as s1 http://git-wip-us.apache.org/repos/asf/hive/blob/c7ac3405/ql/src/test/results/clientpositive/spark/windowing.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/spark/windowing.q.out b/ql/src/test/results/clientpositive/spark/windowing.q.out index 8eba5ae..e72babc 100644 --- a/ql/src/test/results/clientpositive/spark/windowing.q.out +++ b/ql/src/test/results/clientpositive/spark/windowing.q.out @@ -950,6 +950,9 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: default@part POSTHOOK: Output: database:default POSTHOOK: Output: default@mfgr_price_view +POSTHOOK: Lineage: mfgr_price_view.p_brand SIMPLE [(part)part.FieldSchema(name:p_brand, type:string, comment:null), ] +POSTHOOK: Lineage: mfgr_price_view.p_mfgr SIMPLE [(part)part.FieldSchema(name:p_mfgr, type:string, comment:null), ] +POSTHOOK: Lineage: mfgr_price_view.s EXPRESSION [(part)part.FieldSchema(name:p_retailprice, type:double, comment:null), ] PREHOOK: query: select * from ( select p_mfgr, p_brand, s, @@ -1040,6 +1043,9 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: default@part POSTHOOK: Output: database:default POSTHOOK: Output: default@mfgr_brand_price_view +POSTHOOK: Lineage: mfgr_brand_price_view.p_brand SIMPLE [(part)part.FieldSchema(name:p_brand, type:string, comment:null), ] +POSTHOOK: Lineage: mfgr_brand_price_view.p_mfgr SIMPLE [(part)part.FieldSchema(name:p_mfgr, type:string, comment:null), ] +POSTHOOK: Lineage: mfgr_brand_price_view.s SCRIPT [(part)part.FieldSchema(name:p_partkey, type:int, comment:null), (part)part.FieldSchema(name:p_name, type:string, comment:null), (part)part.FieldSchema(name:p_mfgr, type:string, comment:null), (part)part.FieldSchema(name:p_brand, type:string, comment:null), (part)part.FieldSchema(name:p_type, type:string, comment:null), (part)part.FieldSchema(name:p_size, type:int, comment:null), (part)part.FieldSchema(name:p_container, type:string, comment:null), (part)part.FieldSchema(name:p_retailprice, type:double, comment:null), (part)part.FieldSchema(name:p_comment, type:string, comment:null), ] PREHOOK: query: select * from mfgr_brand_price_view PREHOOK: type: QUERY PREHOOK: Input: default@mfgr_brand_price_view http://git-wip-us.apache.org/repos/asf/hive/blob/c7ac3405/ql/src/test/results/clientpositive/struct_in_view.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/struct_in_view.q.out b/ql/src/test/results/clientpositive/struct_in_view.q.out index 8d37521..bea35fc 100644 --- a/ql/src/test/results/clientpositive/struct_in_view.q.out +++ b/ql/src/test/results/clientpositive/struct_in_view.q.out @@ -20,6 +20,8 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: default@testreserved POSTHOOK: Output: database:default POSTHOOK: Output: default@testreservedview +POSTHOOK: Lineage: testreservedview.data_end EXPRESSION [(testreserved)testreserved.FieldSchema(name:data, type:struct<end:string,id:string>, comment:null), ] +POSTHOOK: Lineage: testreservedview.data_id EXPRESSION [(testreserved)testreserved.FieldSchema(name:data, type:struct<end:string,id:string>, comment:null), ] PREHOOK: query: describe extended testreservedview PREHOOK: type: DESCTABLE PREHOOK: Input: default@testreservedview @@ -72,6 +74,7 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: default@s POSTHOOK: Output: database:default POSTHOOK: Output: default@vs1 +POSTHOOK: Lineage: vs1.key EXPRESSION [(s)s.FieldSchema(name:default, type:struct<src:struct<end:struct<key:string>,id:string>,id:string>, comment:null), ] PREHOOK: query: describe extended vs1 PREHOOK: type: DESCTABLE PREHOOK: Input: default@vs1 @@ -91,6 +94,7 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: default@s POSTHOOK: Output: database:default POSTHOOK: Output: default@vs2 +POSTHOOK: Lineage: vs2.end EXPRESSION [(s)s.FieldSchema(name:default, type:struct<src:struct<end:struct<key:string>,id:string>,id:string>, comment:null), ] PREHOOK: query: describe extended vs2 PREHOOK: type: DESCTABLE PREHOOK: Input: default@vs2 @@ -126,6 +130,7 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: default@src POSTHOOK: Output: database:default POSTHOOK: Output: default@v +POSTHOOK: Lineage: v.key EXPRESSION [] PREHOOK: query: desc extended v PREHOOK: type: DESCTABLE PREHOOK: Input: default@v @@ -175,6 +180,7 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: default@src POSTHOOK: Output: database:default POSTHOOK: Output: default@v +POSTHOOK: Lineage: v.end EXPRESSION [] PREHOOK: query: desc extended v PREHOOK: type: DESCTABLE PREHOOK: Input: default@v http://git-wip-us.apache.org/repos/asf/hive/blob/c7ac3405/ql/src/test/results/clientpositive/subquery_exists.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/subquery_exists.q.out b/ql/src/test/results/clientpositive/subquery_exists.q.out index 5b8d510..a310e49 100644 --- a/ql/src/test/results/clientpositive/subquery_exists.q.out +++ b/ql/src/test/results/clientpositive/subquery_exists.q.out @@ -221,6 +221,8 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: default@src POSTHOOK: Output: database:default POSTHOOK: Output: default@cv1 +POSTHOOK: Lineage: cv1.key SIMPLE [(src)b.FieldSchema(name:key, type:string, comment:default), ] +POSTHOOK: Lineage: cv1.value SIMPLE [(src)b.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: select * from cv1 PREHOOK: type: QUERY PREHOOK: Input: default@cv1 http://git-wip-us.apache.org/repos/asf/hive/blob/c7ac3405/ql/src/test/results/clientpositive/subquery_exists_having.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/subquery_exists_having.q.out b/ql/src/test/results/clientpositive/subquery_exists_having.q.out index a369c69..96263bf 100644 --- a/ql/src/test/results/clientpositive/subquery_exists_having.q.out +++ b/ql/src/test/results/clientpositive/subquery_exists_having.q.out @@ -479,6 +479,8 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: default@src POSTHOOK: Output: database:default POSTHOOK: Output: default@cv1 +POSTHOOK: Lineage: cv1.c EXPRESSION [(src)b.null, ] +POSTHOOK: Lineage: cv1.key SIMPLE [(src)b.FieldSchema(name:key, type:string, comment:default), ] PREHOOK: query: select * from cv1 PREHOOK: type: QUERY PREHOOK: Input: default@cv1 http://git-wip-us.apache.org/repos/asf/hive/blob/c7ac3405/ql/src/test/results/clientpositive/tez/unionDistinct_2.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/tez/unionDistinct_2.q.out b/ql/src/test/results/clientpositive/tez/unionDistinct_2.q.out index 7cc6324..3b3983f 100644 --- a/ql/src/test/results/clientpositive/tez/unionDistinct_2.q.out +++ b/ql/src/test/results/clientpositive/tez/unionDistinct_2.q.out @@ -338,6 +338,8 @@ POSTHOOK: Input: default@u2 POSTHOOK: Input: default@u3 POSTHOOK: Output: database:default POSTHOOK: Output: default@v +POSTHOOK: Lineage: v.key EXPRESSION [(u1)u1.FieldSchema(name:key, type:string, comment:null), (u2)u2.FieldSchema(name:key, type:string, comment:null), (u3)u3.FieldSchema(name:key, type:string, comment:null), ] +POSTHOOK: Lineage: v.value EXPRESSION [(u1)u1.FieldSchema(name:value, type:string, comment:null), (u2)u2.FieldSchema(name:value, type:string, comment:null), (u3)u3.FieldSchema(name:value, type:string, comment:null), ] PREHOOK: query: describe extended v PREHOOK: type: DESCTABLE PREHOOK: Input: default@v @@ -412,6 +414,8 @@ POSTHOOK: Input: default@u1 POSTHOOK: Input: default@u2 POSTHOOK: Output: database:default POSTHOOK: Output: default@v +POSTHOOK: Lineage: v.key EXPRESSION [(u1)u1.FieldSchema(name:key, type:string, comment:null), (u2)u2.FieldSchema(name:key, type:string, comment:null), ] +POSTHOOK: Lineage: v.value EXPRESSION [(u1)u1.FieldSchema(name:value, type:string, comment:null), (u2)u2.FieldSchema(name:value, type:string, comment:null), ] PREHOOK: query: describe extended v PREHOOK: type: DESCTABLE PREHOOK: Input: default@v @@ -477,6 +481,8 @@ POSTHOOK: Input: default@u1 POSTHOOK: Input: default@u2 POSTHOOK: Output: database:default POSTHOOK: Output: default@v +POSTHOOK: Lineage: v.key EXPRESSION [(u1)u1.FieldSchema(name:key, type:string, comment:null), (u2)u2.FieldSchema(name:key, type:string, comment:null), ] +POSTHOOK: Lineage: v.value EXPRESSION [(u1)u1.FieldSchema(name:value, type:string, comment:null), (u2)u2.FieldSchema(name:value, type:string, comment:null), ] PREHOOK: query: describe extended v PREHOOK: type: DESCTABLE PREHOOK: Input: default@v http://git-wip-us.apache.org/repos/asf/hive/blob/c7ac3405/ql/src/test/results/clientpositive/unicode_comments.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/unicode_comments.q.out b/ql/src/test/results/clientpositive/unicode_comments.q.out index 19413b9..ae50c67 100644 --- a/ql/src/test/results/clientpositive/unicode_comments.q.out +++ b/ql/src/test/results/clientpositive/unicode_comments.q.out @@ -34,6 +34,7 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: unicode_comments_db@unicode_comments_tbl1 POSTHOOK: Output: database:unicode_comments_db POSTHOOK: Output: unicode_comments_db@unicode_comments_view1 +POSTHOOK: Lineage: unicode_comments_view1.col1 SIMPLE [(unicode_comments_tbl1)unicode_comments_tbl1.FieldSchema(name:col1, type:string, comment:第ä¸å), ] PREHOOK: query: create index index2 on table unicode_comments_tbl1(col1) as 'COMPACT' with deferred rebuild comment 'ç´¢å¼' PREHOOK: type: CREATEINDEX PREHOOK: Input: unicode_comments_db@unicode_comments_tbl1 http://git-wip-us.apache.org/repos/asf/hive/blob/c7ac3405/ql/src/test/results/clientpositive/unionall_join_nullconstant.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/unionall_join_nullconstant.q.out b/ql/src/test/results/clientpositive/unionall_join_nullconstant.q.out index cced114..9355b02 100644 --- a/ql/src/test/results/clientpositive/unionall_join_nullconstant.q.out +++ b/ql/src/test/results/clientpositive/unionall_join_nullconstant.q.out @@ -100,6 +100,8 @@ POSTHOOK: Input: default@table_b1 POSTHOOK: Input: default@table_b2 POSTHOOK: Output: database:default POSTHOOK: Output: default@a_view +POSTHOOK: Lineage: a_view.autoname EXPRESSION [(table_a1)a1.FieldSchema(name:composite_key, type:string, comment:null), (table_b1)b1.FieldSchema(name:composite_key, type:string, comment:null), ] +POSTHOOK: Lineage: a_view.col1 EXPRESSION [(table_b1)b1.FieldSchema(name:col1, type:string, comment:null), ] PREHOOK: query: INSERT INTO TABLE table_b1 SELECT * FROM ( SELECT 'something|awful', 'col1' http://git-wip-us.apache.org/repos/asf/hive/blob/c7ac3405/ql/src/test/results/clientpositive/unionall_unbalancedppd.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/unionall_unbalancedppd.q.out b/ql/src/test/results/clientpositive/unionall_unbalancedppd.q.out index 0e8b897..b3e128a 100644 --- a/ql/src/test/results/clientpositive/unionall_unbalancedppd.q.out +++ b/ql/src/test/results/clientpositive/unionall_unbalancedppd.q.out @@ -532,6 +532,8 @@ POSTHOOK: Input: default@map_json1 POSTHOOK: Input: default@map_json2 POSTHOOK: Output: database:default POSTHOOK: Output: default@explode +POSTHOOK: Lineage: explode.id EXPRESSION [(map_json1)map_json1.FieldSchema(name:id, type:int, comment:null), (map_json2)map_json2.FieldSchema(name:id, type:int, comment:null), (map_json)map_json.FieldSchema(name:id, type:int, comment:null), ] +POSTHOOK: Lineage: explode.l SCRIPT [(map_json1)map_json1.FieldSchema(name:val, type:array<string>, comment:null), (map_json2)map_json2.FieldSchema(name:val, type:array<string>, comment:null), (map_json)map_json.FieldSchema(name:val, type:array<string>, comment:null), ] PREHOOK: query: select count(*) from explode where get_json_object(l, '$') is NOT NULL PREHOOK: type: QUERY PREHOOK: Input: default@explode http://git-wip-us.apache.org/repos/asf/hive/blob/c7ac3405/ql/src/test/results/clientpositive/unset_table_view_property.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/unset_table_view_property.q.out b/ql/src/test/results/clientpositive/unset_table_view_property.q.out index f306857..f9c9697 100644 --- a/ql/src/test/results/clientpositive/unset_table_view_property.q.out +++ b/ql/src/test/results/clientpositive/unset_table_view_property.q.out @@ -197,6 +197,7 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: default@src POSTHOOK: Output: database:vt POSTHOOK: Output: vt@testView +POSTHOOK: Lineage: testView.value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: ALTER VIEW vt.testView SET TBLPROPERTIES ('propA'='100', 'propB'='200') PREHOOK: type: ALTERVIEW_PROPERTIES PREHOOK: Input: vt@testview http://git-wip-us.apache.org/repos/asf/hive/blob/c7ac3405/ql/src/test/results/clientpositive/view.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/view.q.out b/ql/src/test/results/clientpositive/view.q.out index 9896d18..07eba08 100644 --- a/ql/src/test/results/clientpositive/view.q.out +++ b/ql/src/test/results/clientpositive/view.q.out @@ -60,6 +60,8 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: db1@table1 POSTHOOK: Output: database:db1 POSTHOOK: Output: db1@v1 +POSTHOOK: Lineage: v1.key SIMPLE [(table1)table1.FieldSchema(name:key, type:string, comment:null), ] +POSTHOOK: Lineage: v1.value SIMPLE [(table1)table1.FieldSchema(name:value, type:string, comment:null), ] PREHOOK: query: CREATE VIEW v2 AS SELECT t1.* FROM table1 t1 PREHOOK: type: CREATEVIEW PREHOOK: Input: db1@table1 @@ -70,6 +72,8 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: db1@table1 POSTHOOK: Output: database:db1 POSTHOOK: Output: db1@v2 +POSTHOOK: Lineage: v2.key SIMPLE [(table1)t1.FieldSchema(name:key, type:string, comment:null), ] +POSTHOOK: Lineage: v2.value SIMPLE [(table1)t1.FieldSchema(name:value, type:string, comment:null), ] PREHOOK: query: CREATE VIEW v3 AS SELECT t1.*, t2.key k FROM table1 t1 JOIN table2 t2 ON t1.key = t2.key PREHOOK: type: CREATEVIEW PREHOOK: Input: db1@table1 @@ -82,6 +86,9 @@ POSTHOOK: Input: db1@table1 POSTHOOK: Input: db1@table2 POSTHOOK: Output: database:db1 POSTHOOK: Output: db1@v3 +POSTHOOK: Lineage: v3.k SIMPLE [(table2)t2.FieldSchema(name:key, type:string, comment:null), ] +POSTHOOK: Lineage: v3.key SIMPLE [(table1)t1.FieldSchema(name:key, type:string, comment:null), ] +POSTHOOK: Lineage: v3.value SIMPLE [(table1)t1.FieldSchema(name:value, type:string, comment:null), ] PREHOOK: query: CREATE VIEW v4 AS SELECT * FROM db1.table1 PREHOOK: type: CREATEVIEW PREHOOK: Input: db1@table1 @@ -92,6 +99,8 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: db1@table1 POSTHOOK: Output: database:db1 POSTHOOK: Output: db1@v4 +POSTHOOK: Lineage: v4.key SIMPLE [(table1)table1.FieldSchema(name:key, type:string, comment:null), ] +POSTHOOK: Lineage: v4.value SIMPLE [(table1)table1.FieldSchema(name:value, type:string, comment:null), ] PREHOOK: query: CREATE VIEW v5 AS SELECT t1.* FROM db1.table1 t1 PREHOOK: type: CREATEVIEW PREHOOK: Input: db1@table1 @@ -102,6 +111,8 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: db1@table1 POSTHOOK: Output: database:db1 POSTHOOK: Output: db1@v5 +POSTHOOK: Lineage: v5.key SIMPLE [(table1)t1.FieldSchema(name:key, type:string, comment:null), ] +POSTHOOK: Lineage: v5.value SIMPLE [(table1)t1.FieldSchema(name:value, type:string, comment:null), ] PREHOOK: query: CREATE VIEW v6 AS SELECT t1.*, t2.key k FROM db1.table1 t1 JOIN db1.table2 t2 ON t1.key = t2.key PREHOOK: type: CREATEVIEW PREHOOK: Input: db1@table1 @@ -114,6 +125,9 @@ POSTHOOK: Input: db1@table1 POSTHOOK: Input: db1@table2 POSTHOOK: Output: database:db1 POSTHOOK: Output: db1@v6 +POSTHOOK: Lineage: v6.k SIMPLE [(table2)t2.FieldSchema(name:key, type:string, comment:null), ] +POSTHOOK: Lineage: v6.key SIMPLE [(table1)t1.FieldSchema(name:key, type:string, comment:null), ] +POSTHOOK: Lineage: v6.value SIMPLE [(table1)t1.FieldSchema(name:value, type:string, comment:null), ] PREHOOK: query: CREATE VIEW v7 AS SELECT key from table1 PREHOOK: type: CREATEVIEW PREHOOK: Input: db1@table1 @@ -124,6 +138,7 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: db1@table1 POSTHOOK: Output: database:db1 POSTHOOK: Output: db1@v7 +POSTHOOK: Lineage: v7.key SIMPLE [(table1)table1.FieldSchema(name:key, type:string, comment:null), ] PREHOOK: query: CREATE VIEW v8 AS SELECT key from db1.table1 PREHOOK: type: CREATEVIEW PREHOOK: Input: db1@table1 @@ -134,6 +149,7 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: db1@table1 POSTHOOK: Output: database:db1 POSTHOOK: Output: db1@v8 +POSTHOOK: Lineage: v8.key SIMPLE [(table1)table1.FieldSchema(name:key, type:string, comment:null), ] PREHOOK: query: CREATE DATABASE db2 PREHOOK: type: CREATEDATABASE PREHOOK: Output: database:db2 http://git-wip-us.apache.org/repos/asf/hive/blob/c7ac3405/ql/src/test/results/clientpositive/view_alias.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/view_alias.q.out b/ql/src/test/results/clientpositive/view_alias.q.out index 4e952bb..0d7e72f 100644 --- a/ql/src/test/results/clientpositive/view_alias.q.out +++ b/ql/src/test/results/clientpositive/view_alias.q.out @@ -12,6 +12,8 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: default@src POSTHOOK: Output: database:default POSTHOOK: Output: default@v +POSTHOOK: Lineage: v._c1 SIMPLE [] +POSTHOOK: Lineage: v.key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] PREHOOK: query: desc formatted v PREHOOK: type: DESCTABLE PREHOOK: Input: default@v @@ -77,6 +79,8 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: default@src POSTHOOK: Output: database:default POSTHOOK: Output: default@v +POSTHOOK: Lineage: v._c1 SIMPLE [] +POSTHOOK: Lineage: v.key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] PREHOOK: query: desc formatted v PREHOOK: type: DESCTABLE PREHOOK: Input: default@v @@ -142,6 +146,9 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: default@src POSTHOOK: Output: database:default POSTHOOK: Output: default@v +POSTHOOK: Lineage: v._c2 SIMPLE [] +POSTHOOK: Lineage: v.key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] +POSTHOOK: Lineage: v.value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: desc formatted v PREHOOK: type: DESCTABLE PREHOOK: Input: default@v @@ -208,6 +215,9 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: default@src POSTHOOK: Output: database:default POSTHOOK: Output: default@v +POSTHOOK: Lineage: v._c121 SIMPLE [] +POSTHOOK: Lineage: v.key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] +POSTHOOK: Lineage: v.value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: desc formatted v PREHOOK: type: DESCTABLE PREHOOK: Input: default@v @@ -274,6 +284,8 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: default@src POSTHOOK: Output: database:default POSTHOOK: Output: default@v +POSTHOOK: Lineage: v._c1 EXPRESSION [(src)src.null, ] +POSTHOOK: Lineage: v.key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] PREHOOK: query: desc formatted v PREHOOK: type: DESCTABLE PREHOOK: Input: default@v @@ -377,6 +389,13 @@ POSTHOOK: Input: default@a POSTHOOK: Input: default@b POSTHOOK: Output: database:default POSTHOOK: Output: default@v +POSTHOOK: Lineage: v._c0 SIMPLE [] +POSTHOOK: Lineage: v._c3 SIMPLE [] +POSTHOOK: Lineage: v._c6 SIMPLE [] +POSTHOOK: Lineage: v.ca SIMPLE [(a)a.FieldSchema(name:ca, type:string, comment:null), ] +POSTHOOK: Lineage: v.caa SIMPLE [(a)a.FieldSchema(name:caa, type:string, comment:null), ] +POSTHOOK: Lineage: v.cb SIMPLE [(b)b.FieldSchema(name:cb, type:string, comment:null), ] +POSTHOOK: Lineage: v.cbb SIMPLE [(b)b.FieldSchema(name:cbb, type:string, comment:null), ] PREHOOK: query: desc formatted v PREHOOK: type: DESCTABLE PREHOOK: Input: default@v http://git-wip-us.apache.org/repos/asf/hive/blob/c7ac3405/ql/src/test/results/clientpositive/view_authorization_sqlstd.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/view_authorization_sqlstd.q.out b/ql/src/test/results/clientpositive/view_authorization_sqlstd.q.out index 3832fcf..4130428 100644 --- a/ql/src/test/results/clientpositive/view_authorization_sqlstd.q.out +++ b/ql/src/test/results/clientpositive/view_authorization_sqlstd.q.out @@ -30,6 +30,8 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: default@t1 POSTHOOK: Output: database:default POSTHOOK: Output: default@vt1 +POSTHOOK: Lineage: vt1.i SIMPLE [(t1)t1.FieldSchema(name:i, type:int, comment:null), ] +POSTHOOK: Lineage: vt1.k SIMPLE [(t1)t1.FieldSchema(name:k, type:int, comment:null), ] PREHOOK: query: create view vt2 as select * from t1 where i > 1 PREHOOK: type: CREATEVIEW PREHOOK: Input: default@t1 @@ -40,6 +42,9 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: default@t1 POSTHOOK: Output: database:default POSTHOOK: Output: default@vt2 +POSTHOOK: Lineage: vt2.i SIMPLE [(t1)t1.FieldSchema(name:i, type:int, comment:null), ] +POSTHOOK: Lineage: vt2.j SIMPLE [(t1)t1.FieldSchema(name:j, type:int, comment:null), ] +POSTHOOK: Lineage: vt2.k SIMPLE [(t1)t1.FieldSchema(name:k, type:int, comment:null), ] PREHOOK: query: show grant user user1 on all PREHOOK: type: SHOW_GRANT POSTHOOK: query: show grant user user1 on all @@ -83,6 +88,8 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: default@t1 POSTHOOK: Output: database:default POSTHOOK: Output: default@vt3 +POSTHOOK: Lineage: vt3.i SIMPLE [(t1)t1.FieldSchema(name:i, type:int, comment:null), ] +POSTHOOK: Lineage: vt3.k SIMPLE [(t1)t1.FieldSchema(name:k, type:int, comment:null), ] PREHOOK: query: show grant user user3 on table vt1 PREHOOK: type: SHOW_GRANT POSTHOOK: query: show grant user user3 on table vt1 http://git-wip-us.apache.org/repos/asf/hive/blob/c7ac3405/ql/src/test/results/clientpositive/view_cast.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/view_cast.q.out b/ql/src/test/results/clientpositive/view_cast.q.out index b771b7f..6c89960 100644 --- a/ql/src/test/results/clientpositive/view_cast.q.out +++ b/ql/src/test/results/clientpositive/view_cast.q.out @@ -63,6 +63,13 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: default@atab POSTHOOK: Output: database:default POSTHOOK: Output: default@aa_view_tw +POSTHOOK: Lineage: aa_view_tw.act SIMPLE [(atab)atab.FieldSchema(name:act, type:string, comment:null), ] +POSTHOOK: Lineage: aa_view_tw.act_date EXPRESSION [(atab)atab.FieldSchema(name:tstamp, type:string, comment:null), ] +POSTHOOK: Lineage: aa_view_tw.at_ks_uid SIMPLE [(atab)atab.FieldSchema(name:at_ks_uid, type:bigint, comment:null), ] +POSTHOOK: Lineage: aa_view_tw.at_sr_uid SIMPLE [(atab)atab.FieldSchema(name:at_sr_uid, type:string, comment:null), ] +POSTHOOK: Lineage: aa_view_tw.content_creation_date EXPRESSION [(atab)atab.FieldSchema(name:original_tstamp, type:string, comment:null), ] +POSTHOOK: Lineage: aa_view_tw.ks_uid SIMPLE [(atab)atab.FieldSchema(name:ks_uid, type:bigint, comment:null), ] +POSTHOOK: Lineage: aa_view_tw.sr_id SIMPLE [(atab)atab.FieldSchema(name:sr_id, type:string, comment:null), ] PREHOOK: query: DROP VIEW IF EXISTS joined_aa_view_tw PREHOOK: type: DROPVIEW POSTHOOK: query: DROP VIEW IF EXISTS joined_aa_view_tw @@ -81,6 +88,15 @@ POSTHOOK: Input: default@atab POSTHOOK: Input: default@mstab POSTHOOK: Output: database:default POSTHOOK: Output: default@joined_aa_view_tw +POSTHOOK: Lineage: joined_aa_view_tw.act SIMPLE [(atab)atab.FieldSchema(name:act, type:string, comment:null), ] +POSTHOOK: Lineage: joined_aa_view_tw.act_date EXPRESSION [(atab)atab.FieldSchema(name:tstamp, type:string, comment:null), ] +POSTHOOK: Lineage: joined_aa_view_tw.at_ks_uid SIMPLE [(atab)atab.FieldSchema(name:at_ks_uid, type:bigint, comment:null), ] +POSTHOOK: Lineage: joined_aa_view_tw.at_ksc EXPRESSION [(mstab)mstab.FieldSchema(name:csc, type:int, comment:null), ] +POSTHOOK: Lineage: joined_aa_view_tw.at_sr_uid SIMPLE [(atab)atab.FieldSchema(name:at_sr_uid, type:string, comment:null), ] +POSTHOOK: Lineage: joined_aa_view_tw.content_creation_date EXPRESSION [(atab)atab.FieldSchema(name:original_tstamp, type:string, comment:null), ] +POSTHOOK: Lineage: joined_aa_view_tw.ks_uid SIMPLE [(atab)atab.FieldSchema(name:ks_uid, type:bigint, comment:null), ] +POSTHOOK: Lineage: joined_aa_view_tw.self_ksc EXPRESSION [(mstab)mstab.FieldSchema(name:csc, type:int, comment:null), ] +POSTHOOK: Lineage: joined_aa_view_tw.sr_id SIMPLE [(atab)atab.FieldSchema(name:sr_id, type:string, comment:null), ] PREHOOK: query: SELECT * FROM joined_aa_view_tw PREHOOK: type: QUERY PREHOOK: Input: default@aa_view_tw http://git-wip-us.apache.org/repos/asf/hive/blob/c7ac3405/ql/src/test/results/clientpositive/view_inputs.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/view_inputs.q.out b/ql/src/test/results/clientpositive/view_inputs.q.out index aa52b33..f4d679f 100644 --- a/ql/src/test/results/clientpositive/view_inputs.q.out +++ b/ql/src/test/results/clientpositive/view_inputs.q.out @@ -8,6 +8,8 @@ POSTHOOK: type: CREATEVIEW POSTHOOK: Input: default@src POSTHOOK: Output: database:default POSTHOOK: Output: default@test_view1 +POSTHOOK: Lineage: test_view1.key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] +POSTHOOK: Lineage: test_view1.value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: CREATE VIEW test_view2 AS SELECT * FROM test_view1 PREHOOK: type: CREATEVIEW PREHOOK: Input: default@src @@ -20,6 +22,8 @@ POSTHOOK: Input: default@src POSTHOOK: Input: default@test_view1 POSTHOOK: Output: database:default POSTHOOK: Output: default@test_view2 +POSTHOOK: Lineage: test_view2.key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] +POSTHOOK: Lineage: test_view2.value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: SELECT COUNT(*) FROM test_view1 a JOIN test_view2 b ON a.key = b.key PREHOOK: type: QUERY PREHOOK: Input: default@src
