diff --git a/ql/src/test/results/clientpositive/infer_bucket_sort_list_bucket.q.out b/ql/src/test/results/clientpositive/infer_bucket_sort_list_bucket.q.out index 0f5738a..839dbab 100644 --- a/ql/src/test/results/clientpositive/infer_bucket_sort_list_bucket.q.out +++ b/ql/src/test/results/clientpositive/infer_bucket_sort_list_bucket.q.out @@ -8,6 +8,7 @@ PARTITIONED BY (part STRING) SKEWED BY (key) ON ("484") STORED AS DIRECTORIES PREHOOK: type: CREATETABLE +PREHOOK: Output: database:default POSTHOOK: query: -- This tests that bucketing/sorting metadata is not inferred for tables with list bucketing -- INCLUDE_HADOOP_MAJOR_VERSIONS(0.23) @@ -18,6 +19,7 @@ PARTITIONED BY (part STRING) SKEWED BY (key) ON ("484") STORED AS DIRECTORIES POSTHOOK: type: CREATETABLE +POSTHOOK: Output: database:default POSTHOOK: Output: default@list_bucketing_table PREHOOK: query: -- Tests group by, the output should neither be bucketed nor sorted @@ -87,12 +89,14 @@ PARTITIONED BY (part STRING) SKEWED BY (key) ON ("abc") STORED AS DIRECTORIES PREHOOK: type: CREATETABLE +PREHOOK: Output: database:default POSTHOOK: query: -- create a table skewed on a key which doesnt exist in the data CREATE TABLE list_bucketing_table2 (key STRING, value STRING) PARTITIONED BY (part STRING) SKEWED BY (key) ON ("abc") STORED AS DIRECTORIES POSTHOOK: type: CREATETABLE +POSTHOOK: Output: database:default POSTHOOK: Output: default@list_bucketing_table2 POSTHOOK: Lineage: list_bucketing_table PARTITION(part=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: list_bucketing_table PARTITION(part=1).value EXPRESSION [(src)src.null, ] diff --git a/ql/src/test/results/clientpositive/list_bucket_dml_1.q.out b/ql/src/test/results/clientpositive/list_bucket_dml_1.q.out index 8a53191..e32b9fe 100644 --- a/ql/src/test/results/clientpositive/list_bucket_dml_1.q.out +++ b/ql/src/test/results/clientpositive/list_bucket_dml_1.q.out @@ -8,6 +8,7 @@ partitioned by (ds String, hr String) skewed by (key) on ("484") stored as DIRECTORIES PREHOOK: type: CREATETABLE +PREHOOK: Output: database:default POSTHOOK: query: -- list bucketing DML : dynamic partition and 2 stage query plan. -- INCLUDE_HADOOP_MAJOR_VERSIONS(0.23) @@ -18,6 +19,7 @@ partitioned by (ds String, hr String) skewed by (key) on ("484") stored as DIRECTORIES POSTHOOK: type: CREATETABLE +POSTHOOK: Output: database:default POSTHOOK: Output: default@list_bucketing_dynamic_part PREHOOK: query: -- list bucketing DML explain extended diff --git a/ql/src/test/results/clientpositive/list_bucket_dml_11.q.out b/ql/src/test/results/clientpositive/list_bucket_dml_11.q.out index 18a9163..5d844fe 100644 --- a/ql/src/test/results/clientpositive/list_bucket_dml_11.q.out +++ b/ql/src/test/results/clientpositive/list_bucket_dml_11.q.out @@ -11,6 +11,7 @@ create table list_bucketing_static_part (key String, value String) stored as DIRECTORIES STORED AS RCFILE PREHOOK: type: CREATETABLE +PREHOOK: Output: database:default POSTHOOK: query: -- Ensure it works if skewed column is not the first column in the table columns -- INCLUDE_HADOOP_MAJOR_VERSIONS(0.23) @@ -24,6 +25,7 @@ create table list_bucketing_static_part (key String, value String) stored as DIRECTORIES STORED AS RCFILE POSTHOOK: type: CREATETABLE +POSTHOOK: Output: database:default POSTHOOK: Output: default@list_bucketing_static_part PREHOOK: query: -- list bucketing DML without merge. use bucketize to generate a few small files. explain extended diff --git a/ql/src/test/results/clientpositive/list_bucket_dml_12.q.out b/ql/src/test/results/clientpositive/list_bucket_dml_12.q.out index 899731f..894b6d3 100644 --- a/ql/src/test/results/clientpositive/list_bucket_dml_12.q.out +++ b/ql/src/test/results/clientpositive/list_bucket_dml_12.q.out @@ -9,6 +9,7 @@ create table list_bucketing_mul_col (col1 String, col2 String, col3 String, col4 stored as DIRECTORIES STORED AS RCFILE PREHOOK: type: CREATETABLE +PREHOOK: Output: database:default POSTHOOK: query: -- Ensure it works if skewed column is not the first column in the table columns -- INCLUDE_HADOOP_MAJOR_VERSIONS(0.23) @@ -20,6 +21,7 @@ create table list_bucketing_mul_col (col1 String, col2 String, col3 String, col4 stored as DIRECTORIES STORED AS RCFILE POSTHOOK: type: CREATETABLE +POSTHOOK: Output: database:default POSTHOOK: Output: default@list_bucketing_mul_col PREHOOK: query: -- list bucketing DML explain extended diff --git a/ql/src/test/results/clientpositive/list_bucket_dml_13.q.out b/ql/src/test/results/clientpositive/list_bucket_dml_13.q.out index 199d4fe..2d21bef 100644 --- a/ql/src/test/results/clientpositive/list_bucket_dml_13.q.out +++ b/ql/src/test/results/clientpositive/list_bucket_dml_13.q.out @@ -9,6 +9,7 @@ create table list_bucketing_mul_col (col1 String, col2 String, col3 String, col4 stored as DIRECTORIES STORED AS RCFILE PREHOOK: type: CREATETABLE +PREHOOK: Output: database:default POSTHOOK: query: -- Ensure skewed value map has escaped directory name -- INCLUDE_HADOOP_MAJOR_VERSIONS(0.23) @@ -20,6 +21,7 @@ create table list_bucketing_mul_col (col1 String, col2 String, col3 String, col4 stored as DIRECTORIES STORED AS RCFILE POSTHOOK: type: CREATETABLE +POSTHOOK: Output: database:default POSTHOOK: Output: default@list_bucketing_mul_col PREHOOK: query: -- list bucketing DML explain extended diff --git a/ql/src/test/results/clientpositive/list_bucket_dml_2.q.out b/ql/src/test/results/clientpositive/list_bucket_dml_2.q.out index 96a6d47..1be44cc 100644 --- a/ql/src/test/results/clientpositive/list_bucket_dml_2.q.out +++ b/ql/src/test/results/clientpositive/list_bucket_dml_2.q.out @@ -18,6 +18,7 @@ create table list_bucketing_static_part (key String, value String) stored as DIRECTORIES STORED AS RCFILE PREHOOK: type: CREATETABLE +PREHOOK: Output: database:default POSTHOOK: query: -- INCLUDE_HADOOP_MAJOR_VERSIONS(0.23) -- list bucketing DML: static partition. multiple skewed columns. @@ -38,6 +39,7 @@ create table list_bucketing_static_part (key String, value String) stored as DIRECTORIES STORED AS RCFILE POSTHOOK: type: CREATETABLE +POSTHOOK: Output: database:default POSTHOOK: Output: default@list_bucketing_static_part PREHOOK: query: -- list bucketing DML without merge. use bucketize to generate a few small files. explain extended diff --git a/ql/src/test/results/clientpositive/list_bucket_dml_3.q.out b/ql/src/test/results/clientpositive/list_bucket_dml_3.q.out index 7ffb860..05804d0 100644 --- a/ql/src/test/results/clientpositive/list_bucket_dml_3.q.out +++ b/ql/src/test/results/clientpositive/list_bucket_dml_3.q.out @@ -5,6 +5,7 @@ PREHOOK: query: -- list bucketing DML : static partition and 2 stage query plan. -- create a skewed table create table list_bucketing_static_part (key String, value String) partitioned by (ds String, hr String) skewed by (key) on ("484") stored as DIRECTORIES PREHOOK: type: CREATETABLE +PREHOOK: Output: database:default POSTHOOK: query: -- list bucketing DML : static partition and 2 stage query plan. -- INCLUDE_HADOOP_MAJOR_VERSIONS(0.23) @@ -12,6 +13,7 @@ POSTHOOK: query: -- list bucketing DML : static partition and 2 stage query plan -- create a skewed table create table list_bucketing_static_part (key String, value String) partitioned by (ds String, hr String) skewed by (key) on ("484") stored as DIRECTORIES POSTHOOK: type: CREATETABLE +POSTHOOK: Output: database:default POSTHOOK: Output: default@list_bucketing_static_part PREHOOK: query: -- list bucketing DML explain extended diff --git a/ql/src/test/results/clientpositive/list_bucket_dml_5.q.out b/ql/src/test/results/clientpositive/list_bucket_dml_5.q.out index 6c086d7..b0a2127 100644 --- a/ql/src/test/results/clientpositive/list_bucket_dml_5.q.out +++ b/ql/src/test/results/clientpositive/list_bucket_dml_5.q.out @@ -8,6 +8,7 @@ partitioned by (ds String, hr String) skewed by (key, value) on (('484','val_484'),('51','val_14'),('103','val_103')) stored as DIRECTORIES PREHOOK: type: CREATETABLE +PREHOOK: Output: database:default POSTHOOK: query: -- list bucketing DML: multiple skewed columns. 2 stages -- INCLUDE_HADOOP_MAJOR_VERSIONS(0.23) @@ -18,6 +19,7 @@ partitioned by (ds String, hr String) skewed by (key, value) on (('484','val_484'),('51','val_14'),('103','val_103')) stored as DIRECTORIES POSTHOOK: type: CREATETABLE +POSTHOOK: Output: database:default POSTHOOK: Output: default@list_bucketing_dynamic_part PREHOOK: query: -- list bucketing DML explain extended diff --git a/ql/src/test/results/clientpositive/list_bucket_dml_6.q.out b/ql/src/test/results/clientpositive/list_bucket_dml_6.q.out index 8738f15..cf6c34d 100644 --- a/ql/src/test/results/clientpositive/list_bucket_dml_6.q.out +++ b/ql/src/test/results/clientpositive/list_bucket_dml_6.q.out @@ -45,6 +45,7 @@ create table list_bucketing_dynamic_part (key String, value String) stored as DIRECTORIES STORED AS RCFILE PREHOOK: type: CREATETABLE +PREHOOK: Output: database:default POSTHOOK: query: -- list bucketing DML: dynamic partition. multiple skewed columns. merge. -- The following explains merge example used in this test case -- DML will generated 2 partitions @@ -92,6 +93,7 @@ create table list_bucketing_dynamic_part (key String, value String) stored as DIRECTORIES STORED AS RCFILE POSTHOOK: type: CREATETABLE +POSTHOOK: Output: database:default POSTHOOK: Output: default@list_bucketing_dynamic_part PREHOOK: query: -- list bucketing DML without merge. use bucketize to generate a few small files. explain extended diff --git a/ql/src/test/results/clientpositive/list_bucket_dml_7.q.out b/ql/src/test/results/clientpositive/list_bucket_dml_7.q.out index f8220ec..863203f 100644 --- a/ql/src/test/results/clientpositive/list_bucket_dml_7.q.out +++ b/ql/src/test/results/clientpositive/list_bucket_dml_7.q.out @@ -19,6 +19,7 @@ CREATE TABLE list_bucketing_dynamic_part (key String, value STRING) stored as DIRECTORIES STORED AS RCFILE PREHOOK: type: CREATETABLE +PREHOOK: Output: database:default POSTHOOK: query: -- INCLUDE_HADOOP_MAJOR_VERSIONS(0.23) -- list bucketing DML : dynamic partition (one level) , merge , one skewed column @@ -40,6 +41,7 @@ CREATE TABLE list_bucketing_dynamic_part (key String, value STRING) stored as DIRECTORIES STORED AS RCFILE POSTHOOK: type: CREATETABLE +POSTHOOK: Output: database:default POSTHOOK: Output: default@list_bucketing_dynamic_part PREHOOK: query: -- list bucketing DML without merge. use bucketize to generate a few small files. explain extended diff --git a/ql/src/test/results/clientpositive/list_bucket_dml_9.q.out b/ql/src/test/results/clientpositive/list_bucket_dml_9.q.out index 9d0eb29..3cab1a5 100644 --- a/ql/src/test/results/clientpositive/list_bucket_dml_9.q.out +++ b/ql/src/test/results/clientpositive/list_bucket_dml_9.q.out @@ -22,6 +22,7 @@ create table list_bucketing_static_part (key String, value String) stored as DIRECTORIES STORED AS RCFILE PREHOOK: type: CREATETABLE +PREHOOK: Output: database:default POSTHOOK: query: -- INCLUDE_HADOOP_MAJOR_VERSIONS(0.23) -- list bucketing DML: static partition. multiple skewed columns. merge. @@ -46,6 +47,7 @@ create table list_bucketing_static_part (key String, value String) stored as DIRECTORIES STORED AS RCFILE POSTHOOK: type: CREATETABLE +POSTHOOK: Output: database:default POSTHOOK: Output: default@list_bucketing_static_part PREHOOK: query: -- list bucketing DML without merge. use bucketize to generate a few small files. explain extended diff --git a/ql/src/test/results/clientpositive/list_bucket_query_multiskew_1.q.out b/ql/src/test/results/clientpositive/list_bucket_query_multiskew_1.q.out index bb5deee..5113e96 100644 --- a/ql/src/test/results/clientpositive/list_bucket_query_multiskew_1.q.out +++ b/ql/src/test/results/clientpositive/list_bucket_query_multiskew_1.q.out @@ -17,6 +17,7 @@ partitioned by (ds String, hr String) skewed by (key, value) on (('484','val_484'),('238','val_238')) stored as DIRECTORIES PREHOOK: type: CREATETABLE +PREHOOK: Output: database:default POSTHOOK: query: -- INCLUDE_HADOOP_MAJOR_VERSIONS(0.23) -- List bucketing query logic test case. We simulate the directory structure by DML here. @@ -36,6 +37,7 @@ partitioned by (ds String, hr String) skewed by (key, value) on (('484','val_484'),('238','val_238')) stored as DIRECTORIES POSTHOOK: type: CREATETABLE +POSTHOOK: Output: database:default POSTHOOK: Output: default@fact_daily PREHOOK: query: insert overwrite table fact_daily partition (ds = '1', hr = '4') select key, value from src diff --git a/ql/src/test/results/clientpositive/list_bucket_query_multiskew_2.q.out b/ql/src/test/results/clientpositive/list_bucket_query_multiskew_2.q.out index 4aa8903..fd122df 100644 --- a/ql/src/test/results/clientpositive/list_bucket_query_multiskew_2.q.out +++ b/ql/src/test/results/clientpositive/list_bucket_query_multiskew_2.q.out @@ -16,6 +16,7 @@ partitioned by (ds String, hr String) skewed by (key, value) on (('484','val_484'),('238','val_238')) stored as DIRECTORIES PREHOOK: type: CREATETABLE +PREHOOK: Output: database:default POSTHOOK: query: -- INCLUDE_HADOOP_MAJOR_VERSIONS(0.23) -- List bucketing query logic test case. We simulate the directory structure by DML here. @@ -34,6 +35,7 @@ partitioned by (ds String, hr String) skewed by (key, value) on (('484','val_484'),('238','val_238')) stored as DIRECTORIES POSTHOOK: type: CREATETABLE +POSTHOOK: Output: database:default POSTHOOK: Output: default@fact_daily PREHOOK: query: insert overwrite table fact_daily partition (ds = '1', hr = '4') select key, value from src diff --git a/ql/src/test/results/clientpositive/list_bucket_query_multiskew_3.q.out b/ql/src/test/results/clientpositive/list_bucket_query_multiskew_3.q.out index be8acbb..f762eee 100644 --- a/ql/src/test/results/clientpositive/list_bucket_query_multiskew_3.q.out +++ b/ql/src/test/results/clientpositive/list_bucket_query_multiskew_3.q.out @@ -16,6 +16,7 @@ PREHOOK: query: -- INCLUDE_HADOOP_MAJOR_VERSIONS(0.23) create table fact_daily (key String, value String) partitioned by (ds String, hr String) PREHOOK: type: CREATETABLE +PREHOOK: Output: database:default POSTHOOK: query: -- INCLUDE_HADOOP_MAJOR_VERSIONS(0.23) -- List bucketing query logic test case. We simulate the directory structure by DML here. @@ -34,6 +35,7 @@ POSTHOOK: query: -- INCLUDE_HADOOP_MAJOR_VERSIONS(0.23) create table fact_daily (key String, value String) partitioned by (ds String, hr String) POSTHOOK: type: CREATETABLE +POSTHOOK: Output: database:default POSTHOOK: Output: default@fact_daily PREHOOK: query: -- partition no skew insert overwrite table fact_daily partition (ds = '1', hr = '1') diff --git a/ql/src/test/results/clientpositive/list_bucket_query_oneskew_1.q.out b/ql/src/test/results/clientpositive/list_bucket_query_oneskew_1.q.out index 224fd84..98a1a70 100644 --- a/ql/src/test/results/clientpositive/list_bucket_query_oneskew_1.q.out +++ b/ql/src/test/results/clientpositive/list_bucket_query_oneskew_1.q.out @@ -14,6 +14,7 @@ PREHOOK: query: -- INCLUDE_HADOOP_MAJOR_VERSIONS(0.23) -- fact_tz is a table used to prepare data and test directories CREATE TABLE fact_daily(x int) PARTITIONED BY (ds STRING) PREHOOK: type: CREATETABLE +PREHOOK: Output: database:default POSTHOOK: query: -- INCLUDE_HADOOP_MAJOR_VERSIONS(0.23) -- List bucketing query logic test case. @@ -30,13 +31,18 @@ POSTHOOK: query: -- INCLUDE_HADOOP_MAJOR_VERSIONS(0.23) -- fact_tz is a table used to prepare data and test directories CREATE TABLE fact_daily(x int) PARTITIONED BY (ds STRING) POSTHOOK: type: CREATETABLE +POSTHOOK: Output: database:default POSTHOOK: Output: default@fact_daily PREHOOK: query: CREATE TABLE fact_tz(x int) PARTITIONED BY (ds STRING, hr STRING) #### A masked pattern was here #### PREHOOK: type: CREATETABLE +#### A masked pattern was here #### +PREHOOK: Output: database:default POSTHOOK: query: CREATE TABLE fact_tz(x int) PARTITIONED BY (ds STRING, hr STRING) #### A masked pattern was here #### POSTHOOK: type: CREATETABLE +#### A masked pattern was here #### +POSTHOOK: Output: database:default POSTHOOK: Output: default@fact_tz PREHOOK: query: -- create /fact_tz/ds=1/hr=1 directory INSERT OVERWRITE TABLE fact_tz PARTITION (ds='1', hr='1') @@ -91,11 +97,13 @@ POSTHOOK: Lineage: fact_tz PARTITION(ds=1,hr=2).x EXPRESSION [(src)src.FieldSche PREHOOK: query: ALTER TABLE fact_daily ADD PARTITION (ds='1') #### A masked pattern was here #### PREHOOK: type: ALTERTABLE_ADDPARTS -PREHOOK: Input: default@fact_daily +#### A masked pattern was here #### +PREHOOK: Output: default@fact_daily POSTHOOK: query: ALTER TABLE fact_daily ADD PARTITION (ds='1') #### A masked pattern was here #### POSTHOOK: type: ALTERTABLE_ADDPARTS -POSTHOOK: Input: default@fact_daily +#### A masked pattern was here #### +POSTHOOK: Output: default@fact_daily POSTHOOK: Output: default@fact_daily@ds=1 POSTHOOK: Lineage: fact_tz PARTITION(ds=1,hr=1).x EXPRESSION [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: fact_tz PARTITION(ds=1,hr=2).x EXPRESSION [(src)src.FieldSchema(name:key, type:string, comment:default), ] @@ -104,12 +112,14 @@ PREHOOK: query: -- set List Bucketing location map PREHOOK: type: ALTERTBLPART_SKEWED_LOCATION PREHOOK: Input: default@fact_daily PREHOOK: Output: default@fact_daily@ds=1 +#### A masked pattern was here #### POSTHOOK: query: -- set List Bucketing location map #### A masked pattern was here #### POSTHOOK: type: ALTERTBLPART_SKEWED_LOCATION POSTHOOK: Input: default@fact_daily POSTHOOK: Input: default@fact_daily@ds=1 POSTHOOK: Output: default@fact_daily@ds=1 +#### A masked pattern was here #### POSTHOOK: Lineage: fact_tz PARTITION(ds=1,hr=1).x EXPRESSION [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: fact_tz PARTITION(ds=1,hr=2).x EXPRESSION [(src)src.FieldSchema(name:key, type:string, comment:default), ] PREHOOK: query: describe formatted fact_daily PARTITION (ds = '1') diff --git a/ql/src/test/results/clientpositive/list_bucket_query_oneskew_2.q.out b/ql/src/test/results/clientpositive/list_bucket_query_oneskew_2.q.out index 3932870..99be253 100644 --- a/ql/src/test/results/clientpositive/list_bucket_query_oneskew_2.q.out +++ b/ql/src/test/results/clientpositive/list_bucket_query_oneskew_2.q.out @@ -15,6 +15,7 @@ PREHOOK: query: -- INCLUDE_HADOOP_MAJOR_VERSIONS(0.23) -- fact_tz is a table used to prepare data and test directories CREATE TABLE fact_daily(x int, y STRING) PARTITIONED BY (ds STRING) PREHOOK: type: CREATETABLE +PREHOOK: Output: database:default POSTHOOK: query: -- INCLUDE_HADOOP_MAJOR_VERSIONS(0.23) -- List bucketing query logic test case. @@ -32,13 +33,18 @@ POSTHOOK: query: -- INCLUDE_HADOOP_MAJOR_VERSIONS(0.23) -- fact_tz is a table used to prepare data and test directories CREATE TABLE fact_daily(x int, y STRING) PARTITIONED BY (ds STRING) POSTHOOK: type: CREATETABLE +POSTHOOK: Output: database:default POSTHOOK: Output: default@fact_daily PREHOOK: query: CREATE TABLE fact_tz(x int, y STRING) PARTITIONED BY (ds STRING, hr STRING) #### A masked pattern was here #### PREHOOK: type: CREATETABLE +#### A masked pattern was here #### +PREHOOK: Output: database:default POSTHOOK: query: CREATE TABLE fact_tz(x int, y STRING) PARTITIONED BY (ds STRING, hr STRING) #### A masked pattern was here #### POSTHOOK: type: CREATETABLE +#### A masked pattern was here #### +POSTHOOK: Output: database:default POSTHOOK: Output: default@fact_tz PREHOOK: query: -- create /fact_tz/ds=1/hr=1 directory INSERT OVERWRITE TABLE fact_tz PARTITION (ds='1', hr='1') @@ -100,11 +106,13 @@ POSTHOOK: Lineage: fact_tz PARTITION(ds=1,hr=2).y SIMPLE [(src)src.FieldSchema(n PREHOOK: query: ALTER TABLE fact_daily ADD PARTITION (ds='1') #### A masked pattern was here #### PREHOOK: type: ALTERTABLE_ADDPARTS -PREHOOK: Input: default@fact_daily +#### A masked pattern was here #### +PREHOOK: Output: default@fact_daily POSTHOOK: query: ALTER TABLE fact_daily ADD PARTITION (ds='1') #### A masked pattern was here #### POSTHOOK: type: ALTERTABLE_ADDPARTS -POSTHOOK: Input: default@fact_daily +#### A masked pattern was here #### +POSTHOOK: Output: default@fact_daily POSTHOOK: Output: default@fact_daily@ds=1 POSTHOOK: Lineage: fact_tz PARTITION(ds=1,hr=1).x EXPRESSION [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: fact_tz PARTITION(ds=1,hr=1).y SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] @@ -115,12 +123,14 @@ PREHOOK: query: -- set List Bucketing location map PREHOOK: type: ALTERTBLPART_SKEWED_LOCATION PREHOOK: Input: default@fact_daily PREHOOK: Output: default@fact_daily@ds=1 +#### A masked pattern was here #### POSTHOOK: query: -- set List Bucketing location map #### A masked pattern was here #### POSTHOOK: type: ALTERTBLPART_SKEWED_LOCATION POSTHOOK: Input: default@fact_daily POSTHOOK: Input: default@fact_daily@ds=1 POSTHOOK: Output: default@fact_daily@ds=1 +#### A masked pattern was here #### POSTHOOK: Lineage: fact_tz PARTITION(ds=1,hr=1).x EXPRESSION [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: fact_tz PARTITION(ds=1,hr=1).y SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] POSTHOOK: Lineage: fact_tz PARTITION(ds=1,hr=2).x EXPRESSION [(src)src.FieldSchema(name:key, type:string, comment:default), ] diff --git a/ql/src/test/results/clientpositive/list_bucket_query_oneskew_3.q.out b/ql/src/test/results/clientpositive/list_bucket_query_oneskew_3.q.out index 27f31a8..cefa684 100644 --- a/ql/src/test/results/clientpositive/list_bucket_query_oneskew_3.q.out +++ b/ql/src/test/results/clientpositive/list_bucket_query_oneskew_3.q.out @@ -15,6 +15,7 @@ PREHOOK: query: -- INCLUDE_HADOOP_MAJOR_VERSIONS(0.23) -- fact_tz is a table used to prepare data and test directories CREATE TABLE fact_daily(x int, y STRING, z STRING) PARTITIONED BY (ds STRING) PREHOOK: type: CREATETABLE +PREHOOK: Output: database:default POSTHOOK: query: -- INCLUDE_HADOOP_MAJOR_VERSIONS(0.23) -- List bucketing query logic test case. @@ -32,13 +33,18 @@ POSTHOOK: query: -- INCLUDE_HADOOP_MAJOR_VERSIONS(0.23) -- fact_tz is a table used to prepare data and test directories CREATE TABLE fact_daily(x int, y STRING, z STRING) PARTITIONED BY (ds STRING) POSTHOOK: type: CREATETABLE +POSTHOOK: Output: database:default POSTHOOK: Output: default@fact_daily PREHOOK: query: CREATE TABLE fact_tz(x int, y STRING, z STRING) PARTITIONED BY (ds STRING, hr STRING) #### A masked pattern was here #### PREHOOK: type: CREATETABLE +#### A masked pattern was here #### +PREHOOK: Output: database:default POSTHOOK: query: CREATE TABLE fact_tz(x int, y STRING, z STRING) PARTITIONED BY (ds STRING, hr STRING) #### A masked pattern was here #### POSTHOOK: type: CREATETABLE +#### A masked pattern was here #### +POSTHOOK: Output: database:default POSTHOOK: Output: default@fact_tz PREHOOK: query: -- create /fact_tz/ds=1/hr=1 directory INSERT OVERWRITE TABLE fact_tz PARTITION (ds='1', hr='1') @@ -134,11 +140,13 @@ POSTHOOK: Lineage: fact_tz PARTITION(ds=1,hr=3).z SIMPLE [(src)src.FieldSchema(n PREHOOK: query: ALTER TABLE fact_daily ADD PARTITION (ds='1') #### A masked pattern was here #### PREHOOK: type: ALTERTABLE_ADDPARTS -PREHOOK: Input: default@fact_daily +#### A masked pattern was here #### +PREHOOK: Output: default@fact_daily POSTHOOK: query: ALTER TABLE fact_daily ADD PARTITION (ds='1') #### A masked pattern was here #### POSTHOOK: type: ALTERTABLE_ADDPARTS -POSTHOOK: Input: default@fact_daily +#### A masked pattern was here #### +POSTHOOK: Output: default@fact_daily POSTHOOK: Output: default@fact_daily@ds=1 POSTHOOK: Lineage: fact_tz PARTITION(ds=1,hr=1).x EXPRESSION [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: fact_tz PARTITION(ds=1,hr=1).y SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] @@ -154,12 +162,14 @@ PREHOOK: query: -- set List Bucketing location map PREHOOK: type: ALTERTBLPART_SKEWED_LOCATION PREHOOK: Input: default@fact_daily PREHOOK: Output: default@fact_daily@ds=1 +#### A masked pattern was here #### POSTHOOK: query: -- set List Bucketing location map #### A masked pattern was here #### POSTHOOK: type: ALTERTBLPART_SKEWED_LOCATION POSTHOOK: Input: default@fact_daily POSTHOOK: Input: default@fact_daily@ds=1 POSTHOOK: Output: default@fact_daily@ds=1 +#### A masked pattern was here #### POSTHOOK: Lineage: fact_tz PARTITION(ds=1,hr=1).x EXPRESSION [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: fact_tz PARTITION(ds=1,hr=1).y SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] POSTHOOK: Lineage: fact_tz PARTITION(ds=1,hr=1).z SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ]