commit ffbc42ff140e92aa8a3428403163e419658b49ec Author: Andrew Sherman Date: Thu Dec 28 17:06:04 2017 -0800 HIVE-14615: Make temporary values table visible only during the operation that uses it. Background: When values are explicitly inserted via an 'insert into table values ()' statement then the values are saved into a temporary table that is referenced as part of the query tree. The metadata for this table is never stored in HMS but is held in the session state. So these value tables are effectively scoped by the session. The bug is that these tables are visible until the session is exited. Fix: There is code in genValuesTempTable() that generates a temp table out of a value clause at compilation time. Extend this method to create a DropTableDesc task which drops the value table. Store this task in a list of 'cleanupTasks' to be run at the end of the query. Make queries more readable by adding the names of ClassicTokens. Tests: Add a .q test that shows that temporary values tables are deleted after insert completes Remove 'describe formatted values__tmp__table__1;' from encryption_insert_values.q as this table is no longer visible in this way. The comment says "this checks that we've actually created temp table data under encrypted_table folder", but luckily we can actually see this from the output generated by the insert: POSTHOOK: Lineage: encrypted_table.key EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: encrypted_table.value SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] Update some gold files which now show values tables. diff --git hbase-handler/src/test/results/positive/hbase_binary_binary.q.out hbase-handler/src/test/results/positive/hbase_binary_binary.q.out index 0e35cc3f3a247f7a5fad0fc308bab96ababc09a4..30464faf319b04f17d31235ce0861ed3b29c52f0 100644 --- hbase-handler/src/test/results/positive/hbase_binary_binary.q.out +++ hbase-handler/src/test/results/positive/hbase_binary_binary.q.out @@ -20,16 +20,22 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@testhbaseb PREHOOK: query: insert into table testhbaseb values(1, 'hello') PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@testhbaseb POSTHOOK: query: insert into table testhbaseb values(1, 'hello') POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@testhbaseb +POSTHOOK: Output: default@values__tmp__table__1 PREHOOK: query: insert into table testhbaseb values(2, 'hi') PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__2 PREHOOK: Output: default@testhbaseb POSTHOOK: query: insert into table testhbaseb values(2, 'hi') POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__2 POSTHOOK: Output: default@testhbaseb +POSTHOOK: Output: default@values__tmp__table__2 PREHOOK: query: select * from testhbaseb PREHOOK: type: QUERY PREHOOK: Input: default@testhbaseb diff --git ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java index 70fce3266c20420377a09fa6137110235ff2437c..b4b76d9dc5599aaac655aec354d41a5e1dbdda52 100644 --- ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java +++ ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java @@ -164,6 +164,7 @@ import org.apache.hadoop.hive.ql.plan.CreateTableLikeDesc; import org.apache.hadoop.hive.ql.plan.CreateViewDesc; import org.apache.hadoop.hive.ql.plan.DDLWork; +import org.apache.hadoop.hive.ql.plan.DropTableDesc; import org.apache.hadoop.hive.ql.plan.DynamicPartitionCtx; import org.apache.hadoop.hive.ql.plan.ExprNodeColumnDesc; import org.apache.hadoop.hive.ql.plan.ExprNodeColumnListDesc; @@ -339,6 +340,11 @@ CreateTableDesc tableDesc; + /** + * Tasks to run at end of query. + */ + private List> cleanupTasks; + /** Not thread-safe. */ final ASTSearcher astSearcher = new ASTSearcher(); @@ -396,6 +402,7 @@ public SemanticAnalyzer(QueryState queryState) throws SemanticException { tabNameToTabObject = new HashMap<>(); defaultJoinMerge = false == HiveConf.getBoolVar(conf, HiveConf.ConfVars.HIVE_MERGE_NWAY_JOINS); disableJoinMerge = defaultJoinMerge; + cleanupTasks = new ArrayList<>(1); } @Override @@ -970,6 +977,14 @@ private ASTNode genValuesTempTable(ASTNode originalFrom, QB qb) throws SemanticE table.setInputFormatClass(format.getInputFormat()); table.setOutputFormatClass(format.getOutputFormat()); db.createTable(table, false); + + // Step 3, add a cleanup task to drop the temp table + inputs.add(new ReadEntity(table)); + outputs.add(new WriteEntity(table, WriteEntity.WriteType.DDL_EXCLUSIVE)); + DropTableDesc + dropTblDesc = new DropTableDesc(tableName, null, false, true, null); + cleanupTasks.add(TaskFactory.get(new DDLWork(getInputs(), getOutputs(), + dropTblDesc), conf)); } catch (Exception e) { String errMsg = ErrorMsg.INSERT_CANNOT_CREATE_TEMP_FILE.getMsg() + e.getMessage(); LOG.error(errMsg); @@ -986,9 +1001,9 @@ private ASTNode genValuesTempTable(ASTNode originalFrom, QB qb) throws SemanticE // Step 3, return a new subtree with a from clause built around that temp table // The form of the tree is TOK_TABREF->TOK_TABNAME->identifier(tablename) - Token t = new ClassicToken(HiveParser.TOK_TABREF); + Token t = new ClassicToken(HiveParser.TOK_TABREF, "TOK_TABREF"); ASTNode tabRef = new ASTNode(t); - t = new ClassicToken(HiveParser.TOK_TABNAME); + t = new ClassicToken(HiveParser.TOK_TABNAME, "TOK_TABNAME"); ASTNode tabNameNode = new ASTNode(t); tabRef.addChild(tabNameNode); t = new ClassicToken(HiveParser.Identifier, tableName); @@ -11725,6 +11740,9 @@ void analyzeInternal(ASTNode ast, PlannerContextFactory pcf) throws SemanticExce } //find all Acid FileSinkOperatorS QueryPlanPostProcessor qp = new QueryPlanPostProcessor(rootTasks, acidFileSinks, ctx.getExecutionId()); + + // Add any cleanup tasks to the end of rootTasks + rootTasks.addAll(cleanupTasks); LOG.info("Completed plan generation"); // 10. put accessed columns to readEntity diff --git ql/src/test/queries/clientnegative/values_temp_file.q ql/src/test/queries/clientnegative/values_temp_file.q new file mode 100644 index 0000000000000000000000000000000000000000..16ba37c8ed80d2e49bd7c207fcc03cfbf4bd5878 --- /dev/null +++ ql/src/test/queries/clientnegative/values_temp_file.q @@ -0,0 +1,11 @@ +-- test that temporary values tables are deleted after insert completes + +DROP TABLE values_table; +CREATE TABLE values_table (key int); + +INSERT INTO TABLE values_table values(100); +INSERT INTO TABLE values_table values(200); + +show tables 'value__*'; + +describe values__tmp__table__1; diff --git ql/src/test/queries/clientpositive/encryption_insert_values.q ql/src/test/queries/clientpositive/encryption_insert_values.q index c8d1d519f3f01f3fdafc533e6a47f3482d0b1a56..048903adf07a68b8475a3f33ee1793fe49f366e6 100644 --- ql/src/test/queries/clientpositive/encryption_insert_values.q +++ ql/src/test/queries/clientpositive/encryption_insert_values.q @@ -10,7 +10,4 @@ INSERT INTO encrypted_table values(1,'foo'),(2,'bar'); select * from encrypted_table; --- this checks that we've actually created temp table data under encrypted_table folder -describe formatted values__tmp__table__1; - -CRYPTO DELETE_KEY --keyName key_128; +CRYPTO DELETE_KEY --keyName key_128; \ No newline at end of file diff --git ql/src/test/results/clientnegative/values_temp_file.q.out ql/src/test/results/clientnegative/values_temp_file.q.out new file mode 100644 index 0000000000000000000000000000000000000000..56de86778a8887ba293f994f22d25a12f9f2aa9d --- /dev/null +++ ql/src/test/results/clientnegative/values_temp_file.q.out @@ -0,0 +1,37 @@ +PREHOOK: query: DROP TABLE values_table +PREHOOK: type: DROPTABLE +POSTHOOK: query: DROP TABLE values_table +POSTHOOK: type: DROPTABLE +PREHOOK: query: CREATE TABLE values_table (key int) +PREHOOK: type: CREATETABLE +PREHOOK: Output: database:default +PREHOOK: Output: default@values_table +POSTHOOK: query: CREATE TABLE values_table (key int) +POSTHOOK: type: CREATETABLE +POSTHOOK: Output: database:default +POSTHOOK: Output: default@values_table +PREHOOK: query: INSERT INTO TABLE values_table values(100) +PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 +PREHOOK: Output: default@values_table +POSTHOOK: query: INSERT INTO TABLE values_table values(100) +POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 +POSTHOOK: Output: default@values__tmp__table__1 +POSTHOOK: Output: default@values_table +POSTHOOK: Lineage: values_table.key EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] +PREHOOK: query: INSERT INTO TABLE values_table values(200) +PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__2 +PREHOOK: Output: default@values_table +POSTHOOK: query: INSERT INTO TABLE values_table values(200) +POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__2 +POSTHOOK: Output: default@values__tmp__table__2 +POSTHOOK: Output: default@values_table +POSTHOOK: Lineage: values_table.key EXPRESSION [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col1, type:string, comment:), ] +PREHOOK: query: show tables 'value__*' +PREHOOK: type: SHOWTABLES +POSTHOOK: query: show tables 'value__*' +POSTHOOK: type: SHOWTABLES +FAILED: SemanticException [Error 10001]: Table not found values__tmp__table__1 diff --git ql/src/test/results/clientpositive/acid_join.q.out ql/src/test/results/clientpositive/acid_join.q.out index a5c3f933578952e7e222a150a89989e1776d5bce..9420d349ea2bd07cd1d405ca2a622fec7440c0e8 100644 --- ql/src/test/results/clientpositive/acid_join.q.out +++ ql/src/test/results/clientpositive/acid_join.q.out @@ -24,18 +24,24 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@acidjoin3 PREHOOK: query: insert into table acidjoin1 values ('aaa', 35), ('bbb', 32), ('ccc', 32), ('ddd', 35), ('eee', 32) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@acidjoin1 POSTHOOK: query: insert into table acidjoin1 values ('aaa', 35), ('bbb', 32), ('ccc', 32), ('ddd', 35), ('eee', 32) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@acidjoin1 +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: acidjoin1.age EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: acidjoin1.name EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] PREHOOK: query: insert into table acidjoin2 values ('aaa', 3.00), ('bbb', 3.01), ('ccc', 3.02), ('ddd', 3.03), ('eee', 3.04) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__2 PREHOOK: Output: default@acidjoin2 POSTHOOK: query: insert into table acidjoin2 values ('aaa', 3.00), ('bbb', 3.01), ('ccc', 3.02), ('ddd', 3.03), ('eee', 3.04) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__2 POSTHOOK: Output: default@acidjoin2 +POSTHOOK: Output: default@values__tmp__table__2 POSTHOOK: Lineage: acidjoin2.gpa EXPRESSION [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: acidjoin2.name EXPRESSION [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col1, type:string, comment:), ] PREHOOK: query: insert into table acidjoin3 select a.name, age, gpa from acidjoin1 a join acidjoin2 b on (a.name = b.name) diff --git ql/src/test/results/clientpositive/acid_vectorization.q.out ql/src/test/results/clientpositive/acid_vectorization.q.out index 6171ce4390d69d2fdb67b70f5b9098639fd2f19e..6ee56424767dec30484b2f6cef58f52a3c3cc1fc 100644 --- ql/src/test/results/clientpositive/acid_vectorization.q.out +++ ql/src/test/results/clientpositive/acid_vectorization.q.out @@ -18,10 +18,13 @@ POSTHOOK: Lineage: acid_vectorized.a SIMPLE [(alltypesorc)alltypesorc.FieldSchem POSTHOOK: Lineage: acid_vectorized.b SIMPLE [(alltypesorc)alltypesorc.FieldSchema(name:cstring1, type:string, comment:null), ] PREHOOK: query: insert into table acid_vectorized values (1, 'bar') PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@acid_vectorized POSTHOOK: query: insert into table acid_vectorized values (1, 'bar') POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@acid_vectorized +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: acid_vectorized.a EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: acid_vectorized.b SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] PREHOOK: query: update acid_vectorized set b = 'foo' where b = 'bar' diff --git ql/src/test/results/clientpositive/cmdwithcomments.q.out ql/src/test/results/clientpositive/cmdwithcomments.q.out index 151a82c206bfb1f65eb3b085a558dc8ee8691ec4..4da73955566996febd6bc35b443940bd305c1585 100644 --- ql/src/test/results/clientpositive/cmdwithcomments.q.out +++ ql/src/test/results/clientpositive/cmdwithcomments.q.out @@ -11,20 +11,26 @@ POSTHOOK: Output: default@numt PREHOOK: query: --comment2 insert into numt values(1) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@numt POSTHOOK: query: --comment2 insert into numt values(1) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@numt +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: numt.idx EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] PREHOOK: query: --comment3 insert into numt values(2) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__2 PREHOOK: Output: default@numt POSTHOOK: query: --comment3 insert into numt values(2) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__2 POSTHOOK: Output: default@numt +POSTHOOK: Output: default@values__tmp__table__2 POSTHOOK: Lineage: numt.idx EXPRESSION [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col1, type:string, comment:), ] PREHOOK: query: select idx from numt where --comment5 idx = 1 diff --git ql/src/test/results/clientpositive/constantPropWhen.q.out ql/src/test/results/clientpositive/constantPropWhen.q.out index 4f4bf802ed883b23119435f24dc614f4d4c32536..4c4755466a4b9b940c8e32d827da777114dbecc6 100644 --- ql/src/test/results/clientpositive/constantPropWhen.q.out +++ ql/src/test/results/clientpositive/constantPropWhen.q.out @@ -12,10 +12,13 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@test_1 PREHOOK: query: insert into table test_1 values (123, NULL), (NULL, NULL), (NULL, 123), (123, 123) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@test_1 POSTHOOK: query: insert into table test_1 values (123, NULL), (NULL, NULL), (NULL, 123), (123, 123) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@test_1 +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: test_1.id EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: test_1.id2 EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] PREHOOK: query: explain SELECT cast(CASE WHEN id = id2 THEN FALSE ELSE TRUE END AS BOOLEAN) AS b FROM test_1 diff --git ql/src/test/results/clientpositive/encrypted/encryption_insert_partition_dynamic.q.out ql/src/test/results/clientpositive/encrypted/encryption_insert_partition_dynamic.q.out index c4a04b24f400779cd05d458573dae88be7d0ddb5..18f0faf144d41dc47188ae3d6bc9dded3b0b57d7 100644 --- ql/src/test/results/clientpositive/encrypted/encryption_insert_partition_dynamic.q.out +++ ql/src/test/results/clientpositive/encrypted/encryption_insert_partition_dynamic.q.out @@ -36,13 +36,16 @@ PREHOOK: query: insert into table encryptedTable partition (key) values ('val_501', '501'), ('val_502', '502') PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@encryptedtable POSTHOOK: query: insert into table encryptedTable partition (key) values ('val_501', '501'), ('val_502', '502') POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@encryptedtable@key=501 POSTHOOK: Output: default@encryptedtable@key=502 +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: encryptedtable PARTITION(key=501).value SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: encryptedtable PARTITION(key=502).value SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] PREHOOK: query: select * from encryptedTable order by key diff --git ql/src/test/results/clientpositive/encrypted/encryption_insert_partition_static.q.out ql/src/test/results/clientpositive/encrypted/encryption_insert_partition_static.q.out index cd35148f983ae01c889ffbdaa4babdeae9517dfc..9a66ac9ce2fac9c55b27643f11be690eaa99fba9 100644 --- ql/src/test/results/clientpositive/encrypted/encryption_insert_partition_static.q.out +++ ql/src/test/results/clientpositive/encrypted/encryption_insert_partition_static.q.out @@ -37,13 +37,16 @@ PREHOOK: query: insert into table encryptedTable partition ('501', 'val_501'), ('502', 'val_502') PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@encryptedtable@ds=today POSTHOOK: query: insert into table encryptedTable partition (ds='today') values ('501', 'val_501'), ('502', 'val_502') POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@encryptedtable@ds=today +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: encryptedtable PARTITION(ds=today).key SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: encryptedtable PARTITION(ds=today).value SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] PREHOOK: query: select * from encryptedTable order by key diff --git ql/src/test/results/clientpositive/encrypted/encryption_insert_values.q.out ql/src/test/results/clientpositive/encrypted/encryption_insert_values.q.out index 9921abd3641dd8142ad659fe2d3866494c337b79..47c6f42462d3d17c8fb8a93d8f891295c6949484 100644 --- ql/src/test/results/clientpositive/encrypted/encryption_insert_values.q.out +++ ql/src/test/results/clientpositive/encrypted/encryption_insert_values.q.out @@ -16,10 +16,13 @@ Encryption key created: 'key_128' Encryption zone created: '/build/ql/test/data/warehouse/default/encrypted_table' using key: 'key_128' PREHOOK: query: INSERT INTO encrypted_table values(1,'foo'),(2,'bar') PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@encrypted_table POSTHOOK: query: INSERT INTO encrypted_table values(1,'foo'),(2,'bar') POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@encrypted_table +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: encrypted_table.key EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: encrypted_table.value SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] PREHOOK: query: select * from encrypted_table @@ -32,30 +35,3 @@ POSTHOOK: Input: default@encrypted_table #### A PARTIAL masked pattern was here #### data/warehouse/default/encrypted_table/.hive-staging 1 foo 2 bar -PREHOOK: query: describe formatted values__tmp__table__1 -PREHOOK: type: DESCTABLE -PREHOOK: Input: default@values__tmp__table__1 -POSTHOOK: query: describe formatted values__tmp__table__1 -POSTHOOK: type: DESCTABLE -POSTHOOK: Input: default@values__tmp__table__1 -# col_name data_type comment -tmp_values_col1 string -tmp_values_col2 string - -# Detailed Table Information -Database: default -#### A masked pattern was here #### -Retention: 0 -#### A PARTIAL masked pattern was here #### data/warehouse/default/encrypted_table/.hive-staging -Table Type: MANAGED_TABLE - -# Storage Information -SerDe Library: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe -InputFormat: org.apache.hadoop.mapred.TextInputFormat -OutputFormat: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat -Compressed: No -Num Buckets: -1 -Bucket Columns: [] -Sort Columns: [] -Storage Desc Params: - serialization.format 1 diff --git ql/src/test/results/clientpositive/equal_ns.q.out ql/src/test/results/clientpositive/equal_ns.q.out index 6a38c0502adb681b8ed218caafd22a6be9d587ad..e5e839feb437f384a2010edf2d8239beda311e5c 100644 --- ql/src/test/results/clientpositive/equal_ns.q.out +++ ql/src/test/results/clientpositive/equal_ns.q.out @@ -8,10 +8,13 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@test PREHOOK: query: insert into test values ('q', 'q'), ('q', 'w'), (NULL, 'q'), ('q', NULL), (NULL, NULL) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@test POSTHOOK: query: insert into test values ('q', 'q'), ('q', 'w'), (NULL, 'q'), ('q', NULL), (NULL, NULL) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@test +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: test.x SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: test.y SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] PREHOOK: query: select *, x<=>y, not (x<=> y), (x <=> y) = false from test diff --git ql/src/test/results/clientpositive/explaindenpendencydiffengs.q.out ql/src/test/results/clientpositive/explaindenpendencydiffengs.q.out index bf1c78135eef4cf3762894e35d8b590b748f2b16..730de33adbd60ae53fd0118911c2d7e165c5aad6 100644 --- ql/src/test/results/clientpositive/explaindenpendencydiffengs.q.out +++ ql/src/test/results/clientpositive/explaindenpendencydiffengs.q.out @@ -12,10 +12,13 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@dependtest PREHOOK: query: insert into table dependtest partition (b=1) values ("hello") PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@dependtest@b=1 POSTHOOK: query: insert into table dependtest partition (b=1) values ("hello") POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@dependtest@b=1 +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: dependtest PARTITION(b=1).a SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] PREHOOK: query: create view viewtest as select * from dependtest where b = 1 PREHOOK: type: CREATEVIEW diff --git ql/src/test/results/clientpositive/folder_predicate.q.out ql/src/test/results/clientpositive/folder_predicate.q.out index 9ad66152a0bfebc6aeaea405e2aad9fc7a172865..e6fe2b36680a6dcefab6c765eb1378d6c1a43f0f 100644 --- ql/src/test/results/clientpositive/folder_predicate.q.out +++ ql/src/test/results/clientpositive/folder_predicate.q.out @@ -12,10 +12,13 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@predicate_fold_tb PREHOOK: query: insert into predicate_fold_tb values(NULL), (1), (2), (3), (4), (5) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@predicate_fold_tb POSTHOOK: query: insert into predicate_fold_tb values(NULL), (1), (2), (3), (4), (5) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@predicate_fold_tb +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: predicate_fold_tb.value EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] PREHOOK: query: explain SELECT * FROM predicate_fold_tb WHERE not(value IS NOT NULL AND value = 3) diff --git ql/src/test/results/clientpositive/groupby_nullvalues.q.out ql/src/test/results/clientpositive/groupby_nullvalues.q.out index 5ad5a985dd3b4f31660357e4688e4d535dccc4c4..5a36c0addbd26ff39d965a44dd86d413e27366a2 100644 --- ql/src/test/results/clientpositive/groupby_nullvalues.q.out +++ ql/src/test/results/clientpositive/groupby_nullvalues.q.out @@ -32,10 +32,15 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@paqtest PREHOOK: query: insert into paqtest values (58, '', 'ABC', 0) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 +PREHOOK: Output: default@Values__Tmp__Table__1 PREHOOK: Output: default@paqtest POSTHOOK: query: insert into paqtest values (58, '', 'ABC', 0) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 +POSTHOOK: Output: default@Values__Tmp__Table__1 POSTHOOK: Output: default@paqtest +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: paqtest.bn1 EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col4, type:string, comment:), ] POSTHOOK: Lineage: paqtest.c1 EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: paqtest.s1 SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] diff --git ql/src/test/results/clientpositive/insert_nonacid_from_acid.q.out ql/src/test/results/clientpositive/insert_nonacid_from_acid.q.out index 4aded00f88c1b7bcbf6db0ccd5ebf7fcc9bc37ec..a900735daf37889da068237005d6391f8fa1186a 100644 --- ql/src/test/results/clientpositive/insert_nonacid_from_acid.q.out +++ ql/src/test/results/clientpositive/insert_nonacid_from_acid.q.out @@ -8,10 +8,13 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@sample_06 PREHOOK: query: insert into table sample_06 values ('aaa', 35, 3.00), ('bbb', 32, 3.00), ('ccc', 32, 3.00), ('ddd', 35, 3.00), ('eee', 32, 3.00) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@sample_06 POSTHOOK: query: insert into table sample_06 values ('aaa', 35, 3.00), ('bbb', 32, 3.00), ('ccc', 32, 3.00), ('ddd', 35, 3.00), ('eee', 32, 3.00) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@sample_06 +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: sample_06.age EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: sample_06.gpa EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col3, type:string, comment:), ] POSTHOOK: Lineage: sample_06.name EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] diff --git ql/src/test/results/clientpositive/insert_values_acid_not_bucketed.q.out ql/src/test/results/clientpositive/insert_values_acid_not_bucketed.q.out index 7885ee44ee9c1f7484f4b844d8a79ae771ec8f65..b9391300332cc555c444107c82e9eb5875890108 100644 --- ql/src/test/results/clientpositive/insert_values_acid_not_bucketed.q.out +++ ql/src/test/results/clientpositive/insert_values_acid_not_bucketed.q.out @@ -8,10 +8,13 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@acid_notbucketed PREHOOK: query: insert into table acid_notbucketed values (1, 'abc'), (2, 'def') PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@acid_notbucketed POSTHOOK: query: insert into table acid_notbucketed values (1, 'abc'), (2, 'def') POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@acid_notbucketed +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: acid_notbucketed.a EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: acid_notbucketed.b EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] PREHOOK: query: select * from acid_notbucketed diff --git ql/src/test/results/clientpositive/insert_values_dynamic_partitioned.q.out ql/src/test/results/clientpositive/insert_values_dynamic_partitioned.q.out index 7da63939bd0b3560efafb63ca387088894d93939..0dd9edb68362bb294ab86c9c0cb91697bbe82a27 100644 --- ql/src/test/results/clientpositive/insert_values_dynamic_partitioned.q.out +++ ql/src/test/results/clientpositive/insert_values_dynamic_partitioned.q.out @@ -14,13 +14,16 @@ PREHOOK: query: insert into table ivdp partition (ds) values (1, 109.23, 'and everywhere that mary went', 'today'), (6553, 923.19, 'the lamb was sure to go', 'tomorrow') PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@ivdp POSTHOOK: query: insert into table ivdp partition (ds) values (1, 109.23, 'and everywhere that mary went', 'today'), (6553, 923.19, 'the lamb was sure to go', 'tomorrow') POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@ivdp@ds=today POSTHOOK: Output: default@ivdp@ds=tomorrow +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: ivdp PARTITION(ds=today).de EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: ivdp PARTITION(ds=today).i EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: ivdp PARTITION(ds=today).vc EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col3, type:string, comment:), ] diff --git ql/src/test/results/clientpositive/insert_values_non_partitioned.q.out ql/src/test/results/clientpositive/insert_values_non_partitioned.q.out index 189f50d84d19616bbb78a37d935556dedb99ba05..329156050d1b9cb891c5c4b9f413e872703cc651 100644 --- ql/src/test/results/clientpositive/insert_values_non_partitioned.q.out +++ ql/src/test/results/clientpositive/insert_values_non_partitioned.q.out @@ -35,13 +35,16 @@ PREHOOK: query: insert into table acid_ivnp values (null, null, null, null, null, null, null, null, null, null, null, null, null), (3, 25, 6553, null, 0.14, 1923.141592654, 1.2301, '2014-08-24 17:21:30.0', '2014-08-26', false, 'its fleece was white as snow', 'a pocket full of posies', 'blue' ) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@acid_ivnp POSTHOOK: query: insert into table acid_ivnp values (1, 257, 65537, 4294967297, 3.14, 3.141592654, 109.23, '2014-08-25 17:21:30.0', '2014-08-25', true, 'mary had a little lamb', 'ring around the rosie', 'red'), (null, null, null, null, null, null, null, null, null, null, null, null, null), (3, 25, 6553, null, 0.14, 1923.141592654, 1.2301, '2014-08-24 17:21:30.0', '2014-08-26', false, 'its fleece was white as snow', 'a pocket full of posies', 'blue' ) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@acid_ivnp +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: acid_ivnp.b EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col10, type:string, comment:), ] POSTHOOK: Lineage: acid_ivnp.bi EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col4, type:string, comment:), ] POSTHOOK: Lineage: acid_ivnp.ch EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col13, type:string, comment:), ] diff --git ql/src/test/results/clientpositive/insert_values_nonascii.q.out ql/src/test/results/clientpositive/insert_values_nonascii.q.out index 62514da30d90e322c916b410656ad3fb4747e870..33626f115195bb45c8d1bdf6015ed051ce8eca16 100644 --- ql/src/test/results/clientpositive/insert_values_nonascii.q.out +++ ql/src/test/results/clientpositive/insert_values_nonascii.q.out @@ -8,10 +8,13 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@insert_values_nonascii PREHOOK: query: insert into insert_values_nonascii values("Абвгде Garçu 谢谢", "Kôkaku ありがとう"), ("ございます", "kidôtai한국어") PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@insert_values_nonascii POSTHOOK: query: insert into insert_values_nonascii values("Абвгде Garçu 谢谢", "Kôkaku ありがとう"), ("ございます", "kidôtai한국어") POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@insert_values_nonascii +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: insert_values_nonascii.t1 EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: insert_values_nonascii.t2 SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] PREHOOK: query: select * from insert_values_nonascii diff --git ql/src/test/results/clientpositive/insert_values_partitioned.q.out ql/src/test/results/clientpositive/insert_values_partitioned.q.out index 48dfadc1aa240e36dfca2159f9ecff5915c4c876..47014200b97a505dd417a3df83c7944807d11632 100644 --- ql/src/test/results/clientpositive/insert_values_partitioned.q.out +++ ql/src/test/results/clientpositive/insert_values_partitioned.q.out @@ -32,12 +32,15 @@ PREHOOK: query: insert into table acid_ivp partition (ds='today') values (1, 257, 65537, 4294967297, 3.14, 3.141592654, 109.23, '2014-08-25 17:21:30.0', '2014-08-25', 'mary had a little lamb', 'ring around the rosie', 'red'), (3, 25, 6553, 429496729, 0.14, 1923.141592654, 1.2301, '2014-08-24 17:21:30.0', '2014-08-26', 'its fleece was white as snow', 'a pocket full of posies', 'blue') PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@acid_ivp@ds=today POSTHOOK: query: insert into table acid_ivp partition (ds='today') values (1, 257, 65537, 4294967297, 3.14, 3.141592654, 109.23, '2014-08-25 17:21:30.0', '2014-08-25', 'mary had a little lamb', 'ring around the rosie', 'red'), (3, 25, 6553, 429496729, 0.14, 1923.141592654, 1.2301, '2014-08-24 17:21:30.0', '2014-08-26', 'its fleece was white as snow', 'a pocket full of posies', 'blue') POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@acid_ivp@ds=today +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: acid_ivp PARTITION(ds=today).bi EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col4, type:string, comment:), ] POSTHOOK: Lineage: acid_ivp PARTITION(ds=today).ch EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col12, type:string, comment:), ] POSTHOOK: Lineage: acid_ivp PARTITION(ds=today).d EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col6, type:string, comment:), ] diff --git ql/src/test/results/clientpositive/insert_values_tmp_table.q.out ql/src/test/results/clientpositive/insert_values_tmp_table.q.out index 4e4eafd85f1a78ff1cb95092026a43ec304cfaa1..5deb783073cea938cbe8c515cdaa437d9013d572 100644 --- ql/src/test/results/clientpositive/insert_values_tmp_table.q.out +++ ql/src/test/results/clientpositive/insert_values_tmp_table.q.out @@ -11,13 +11,16 @@ PREHOOK: query: insert into table acid_ivtt values (429496729, 0.14, 'its fleece was white as snow'), (-29496729, -0.14, 'negative values test') PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@acid_ivtt POSTHOOK: query: insert into table acid_ivtt values (1, 109.23, 'mary had a little lamb'), (429496729, 0.14, 'its fleece was white as snow'), (-29496729, -0.14, 'negative values test') POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@acid_ivtt +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: acid_ivtt.de EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: acid_ivtt.i EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: acid_ivtt.vc EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col3, type:string, comment:), ] diff --git ql/src/test/results/clientpositive/insertoverwrite_bucket.q.out ql/src/test/results/clientpositive/insertoverwrite_bucket.q.out index ed97f83906209beacc52d9b5e73cb8d86bc5f922..87728f35f705a2ebda87516713bb92f5179ef4fe 100644 --- ql/src/test/results/clientpositive/insertoverwrite_bucket.q.out +++ ql/src/test/results/clientpositive/insertoverwrite_bucket.q.out @@ -46,24 +46,33 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@bucketoutput2 PREHOOK: query: insert into table bucketinput values ("firstinsert1") PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@bucketinput POSTHOOK: query: insert into table bucketinput values ("firstinsert1") POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@bucketinput +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: bucketinput.data SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] PREHOOK: query: insert into table bucketinput values ("firstinsert2") PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__2 PREHOOK: Output: default@bucketinput POSTHOOK: query: insert into table bucketinput values ("firstinsert2") POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__2 POSTHOOK: Output: default@bucketinput +POSTHOOK: Output: default@values__tmp__table__2 POSTHOOK: Lineage: bucketinput.data SIMPLE [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col1, type:string, comment:), ] PREHOOK: query: insert into table bucketinput values ("firstinsert3") PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__3 PREHOOK: Output: default@bucketinput POSTHOOK: query: insert into table bucketinput values ("firstinsert3") POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__3 POSTHOOK: Output: default@bucketinput +POSTHOOK: Output: default@values__tmp__table__3 POSTHOOK: Lineage: bucketinput.data SIMPLE [(values__tmp__table__3)values__tmp__table__3.FieldSchema(name:tmp_values_col1, type:string, comment:), ] PREHOOK: query: insert overwrite table bucketoutput1 select * from bucketinput where data like 'first%' PREHOOK: type: QUERY diff --git ql/src/test/results/clientpositive/join42.q.out ql/src/test/results/clientpositive/join42.q.out index 11851a9c88715a742a3635990ed6f899c12b2299..7b742d2eb67175336d2c0c4a655f35f2c9299a43 100644 --- ql/src/test/results/clientpositive/join42.q.out +++ ql/src/test/results/clientpositive/join42.q.out @@ -70,19 +70,25 @@ POSTHOOK: Lineage: acct.aid SIMPLE [] POSTHOOK: Lineage: acct.brn SIMPLE [] PREHOOK: query: insert into table acct values(4748, null, null) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@acct POSTHOOK: query: insert into table acct values(4748, null, null) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@acct +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: acct.acc_n EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: acct.aid EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: acct.brn EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col3, type:string, comment:), ] PREHOOK: query: insert into table acct values(4748, null, null) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__2 PREHOOK: Output: default@acct POSTHOOK: query: insert into table acct values(4748, null, null) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__2 POSTHOOK: Output: default@acct +POSTHOOK: Output: default@values__tmp__table__2 POSTHOOK: Lineage: acct.acc_n EXPRESSION [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: acct.aid EXPRESSION [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: acct.brn EXPRESSION [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col3, type:string, comment:), ] diff --git ql/src/test/results/clientpositive/join43.q.out ql/src/test/results/clientpositive/join43.q.out index fac8a8cb2db69f36c7bcb473a43f9a2fb3d16662..9fdf46bf57572cfd00b7963dea63ee1883fc233d 100644 --- ql/src/test/results/clientpositive/join43.q.out +++ ql/src/test/results/clientpositive/join43.q.out @@ -8,40 +8,52 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@purchase_history PREHOOK: query: insert into purchase_history values ('1', 'Belt', 20.00, 21) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@purchase_history POSTHOOK: query: insert into purchase_history values ('1', 'Belt', 20.00, 21) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@purchase_history +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: purchase_history.price EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col3, type:string, comment:), ] POSTHOOK: Lineage: purchase_history.product SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: purchase_history.s SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: purchase_history.time EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col4, type:string, comment:), ] PREHOOK: query: insert into purchase_history values ('1', 'Socks', 3.50, 31) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__2 PREHOOK: Output: default@purchase_history POSTHOOK: query: insert into purchase_history values ('1', 'Socks', 3.50, 31) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__2 POSTHOOK: Output: default@purchase_history +POSTHOOK: Output: default@values__tmp__table__2 POSTHOOK: Lineage: purchase_history.price EXPRESSION [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col3, type:string, comment:), ] POSTHOOK: Lineage: purchase_history.product SIMPLE [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: purchase_history.s SIMPLE [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: purchase_history.time EXPRESSION [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col4, type:string, comment:), ] PREHOOK: query: insert into purchase_history values ('3', 'Belt', 20.00, 51) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__3 PREHOOK: Output: default@purchase_history POSTHOOK: query: insert into purchase_history values ('3', 'Belt', 20.00, 51) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__3 POSTHOOK: Output: default@purchase_history +POSTHOOK: Output: default@values__tmp__table__3 POSTHOOK: Lineage: purchase_history.price EXPRESSION [(values__tmp__table__3)values__tmp__table__3.FieldSchema(name:tmp_values_col3, type:string, comment:), ] POSTHOOK: Lineage: purchase_history.product SIMPLE [(values__tmp__table__3)values__tmp__table__3.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: purchase_history.s SIMPLE [(values__tmp__table__3)values__tmp__table__3.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: purchase_history.time EXPRESSION [(values__tmp__table__3)values__tmp__table__3.FieldSchema(name:tmp_values_col4, type:string, comment:), ] PREHOOK: query: insert into purchase_history values ('4', 'Shirt', 15.50, 59) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__4 PREHOOK: Output: default@purchase_history POSTHOOK: query: insert into purchase_history values ('4', 'Shirt', 15.50, 59) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__4 POSTHOOK: Output: default@purchase_history +POSTHOOK: Output: default@values__tmp__table__4 POSTHOOK: Lineage: purchase_history.price EXPRESSION [(values__tmp__table__4)values__tmp__table__4.FieldSchema(name:tmp_values_col3, type:string, comment:), ] POSTHOOK: Lineage: purchase_history.product SIMPLE [(values__tmp__table__4)values__tmp__table__4.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: purchase_history.s SIMPLE [(values__tmp__table__4)values__tmp__table__4.FieldSchema(name:tmp_values_col1, type:string, comment:), ] @@ -56,55 +68,73 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@cart_history PREHOOK: query: insert into cart_history values ('1', 1, 10) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__5 PREHOOK: Output: default@cart_history POSTHOOK: query: insert into cart_history values ('1', 1, 10) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__5 POSTHOOK: Output: default@cart_history +POSTHOOK: Output: default@values__tmp__table__5 POSTHOOK: Lineage: cart_history.cart_id EXPRESSION [(values__tmp__table__5)values__tmp__table__5.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: cart_history.s SIMPLE [(values__tmp__table__5)values__tmp__table__5.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: cart_history.time EXPRESSION [(values__tmp__table__5)values__tmp__table__5.FieldSchema(name:tmp_values_col3, type:string, comment:), ] PREHOOK: query: insert into cart_history values ('1', 2, 20) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__6 PREHOOK: Output: default@cart_history POSTHOOK: query: insert into cart_history values ('1', 2, 20) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__6 POSTHOOK: Output: default@cart_history +POSTHOOK: Output: default@values__tmp__table__6 POSTHOOK: Lineage: cart_history.cart_id EXPRESSION [(values__tmp__table__6)values__tmp__table__6.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: cart_history.s SIMPLE [(values__tmp__table__6)values__tmp__table__6.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: cart_history.time EXPRESSION [(values__tmp__table__6)values__tmp__table__6.FieldSchema(name:tmp_values_col3, type:string, comment:), ] PREHOOK: query: insert into cart_history values ('1', 3, 30) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__7 PREHOOK: Output: default@cart_history POSTHOOK: query: insert into cart_history values ('1', 3, 30) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__7 POSTHOOK: Output: default@cart_history +POSTHOOK: Output: default@values__tmp__table__7 POSTHOOK: Lineage: cart_history.cart_id EXPRESSION [(values__tmp__table__7)values__tmp__table__7.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: cart_history.s SIMPLE [(values__tmp__table__7)values__tmp__table__7.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: cart_history.time EXPRESSION [(values__tmp__table__7)values__tmp__table__7.FieldSchema(name:tmp_values_col3, type:string, comment:), ] PREHOOK: query: insert into cart_history values ('1', 4, 40) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__8 PREHOOK: Output: default@cart_history POSTHOOK: query: insert into cart_history values ('1', 4, 40) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__8 POSTHOOK: Output: default@cart_history +POSTHOOK: Output: default@values__tmp__table__8 POSTHOOK: Lineage: cart_history.cart_id EXPRESSION [(values__tmp__table__8)values__tmp__table__8.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: cart_history.s SIMPLE [(values__tmp__table__8)values__tmp__table__8.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: cart_history.time EXPRESSION [(values__tmp__table__8)values__tmp__table__8.FieldSchema(name:tmp_values_col3, type:string, comment:), ] PREHOOK: query: insert into cart_history values ('3', 5, 50) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__9 PREHOOK: Output: default@cart_history POSTHOOK: query: insert into cart_history values ('3', 5, 50) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__9 POSTHOOK: Output: default@cart_history +POSTHOOK: Output: default@values__tmp__table__9 POSTHOOK: Lineage: cart_history.cart_id EXPRESSION [(values__tmp__table__9)values__tmp__table__9.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: cart_history.s SIMPLE [(values__tmp__table__9)values__tmp__table__9.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: cart_history.time EXPRESSION [(values__tmp__table__9)values__tmp__table__9.FieldSchema(name:tmp_values_col3, type:string, comment:), ] PREHOOK: query: insert into cart_history values ('4', 6, 60) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__10 PREHOOK: Output: default@cart_history POSTHOOK: query: insert into cart_history values ('4', 6, 60) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__10 POSTHOOK: Output: default@cart_history +POSTHOOK: Output: default@values__tmp__table__10 POSTHOOK: Lineage: cart_history.cart_id EXPRESSION [(values__tmp__table__10)values__tmp__table__10.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: cart_history.s SIMPLE [(values__tmp__table__10)values__tmp__table__10.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: cart_history.time EXPRESSION [(values__tmp__table__10)values__tmp__table__10.FieldSchema(name:tmp_values_col3, type:string, comment:), ] @@ -118,60 +148,78 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@events PREHOOK: query: insert into events values ('1', 'Bob', 1234, 20) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__11 PREHOOK: Output: default@events POSTHOOK: query: insert into events values ('1', 'Bob', 1234, 20) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__11 POSTHOOK: Output: default@events +POSTHOOK: Output: default@values__tmp__table__11 POSTHOOK: Lineage: events.n EXPRESSION [(values__tmp__table__11)values__tmp__table__11.FieldSchema(name:tmp_values_col3, type:string, comment:), ] POSTHOOK: Lineage: events.s SIMPLE [(values__tmp__table__11)values__tmp__table__11.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: events.st2 SIMPLE [(values__tmp__table__11)values__tmp__table__11.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: events.time EXPRESSION [(values__tmp__table__11)values__tmp__table__11.FieldSchema(name:tmp_values_col4, type:string, comment:), ] PREHOOK: query: insert into events values ('1', 'Bob', 1234, 30) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__12 PREHOOK: Output: default@events POSTHOOK: query: insert into events values ('1', 'Bob', 1234, 30) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__12 POSTHOOK: Output: default@events +POSTHOOK: Output: default@values__tmp__table__12 POSTHOOK: Lineage: events.n EXPRESSION [(values__tmp__table__12)values__tmp__table__12.FieldSchema(name:tmp_values_col3, type:string, comment:), ] POSTHOOK: Lineage: events.s SIMPLE [(values__tmp__table__12)values__tmp__table__12.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: events.st2 SIMPLE [(values__tmp__table__12)values__tmp__table__12.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: events.time EXPRESSION [(values__tmp__table__12)values__tmp__table__12.FieldSchema(name:tmp_values_col4, type:string, comment:), ] PREHOOK: query: insert into events values ('1', 'Bob', 1234, 25) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__13 PREHOOK: Output: default@events POSTHOOK: query: insert into events values ('1', 'Bob', 1234, 25) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__13 POSTHOOK: Output: default@events +POSTHOOK: Output: default@values__tmp__table__13 POSTHOOK: Lineage: events.n EXPRESSION [(values__tmp__table__13)values__tmp__table__13.FieldSchema(name:tmp_values_col3, type:string, comment:), ] POSTHOOK: Lineage: events.s SIMPLE [(values__tmp__table__13)values__tmp__table__13.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: events.st2 SIMPLE [(values__tmp__table__13)values__tmp__table__13.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: events.time EXPRESSION [(values__tmp__table__13)values__tmp__table__13.FieldSchema(name:tmp_values_col4, type:string, comment:), ] PREHOOK: query: insert into events values ('2', 'Sam', 1234, 30) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__14 PREHOOK: Output: default@events POSTHOOK: query: insert into events values ('2', 'Sam', 1234, 30) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__14 POSTHOOK: Output: default@events +POSTHOOK: Output: default@values__tmp__table__14 POSTHOOK: Lineage: events.n EXPRESSION [(values__tmp__table__14)values__tmp__table__14.FieldSchema(name:tmp_values_col3, type:string, comment:), ] POSTHOOK: Lineage: events.s SIMPLE [(values__tmp__table__14)values__tmp__table__14.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: events.st2 SIMPLE [(values__tmp__table__14)values__tmp__table__14.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: events.time EXPRESSION [(values__tmp__table__14)values__tmp__table__14.FieldSchema(name:tmp_values_col4, type:string, comment:), ] PREHOOK: query: insert into events values ('3', 'Jeff', 1234, 50) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__15 PREHOOK: Output: default@events POSTHOOK: query: insert into events values ('3', 'Jeff', 1234, 50) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__15 POSTHOOK: Output: default@events +POSTHOOK: Output: default@values__tmp__table__15 POSTHOOK: Lineage: events.n EXPRESSION [(values__tmp__table__15)values__tmp__table__15.FieldSchema(name:tmp_values_col3, type:string, comment:), ] POSTHOOK: Lineage: events.s SIMPLE [(values__tmp__table__15)values__tmp__table__15.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: events.st2 SIMPLE [(values__tmp__table__15)values__tmp__table__15.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: events.time EXPRESSION [(values__tmp__table__15)values__tmp__table__15.FieldSchema(name:tmp_values_col4, type:string, comment:), ] PREHOOK: query: insert into events values ('4', 'Ted', 1234, 60) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__16 PREHOOK: Output: default@events POSTHOOK: query: insert into events values ('4', 'Ted', 1234, 60) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__16 POSTHOOK: Output: default@events +POSTHOOK: Output: default@values__tmp__table__16 POSTHOOK: Lineage: events.n EXPRESSION [(values__tmp__table__16)values__tmp__table__16.FieldSchema(name:tmp_values_col3, type:string, comment:), ] POSTHOOK: Lineage: events.s SIMPLE [(values__tmp__table__16)values__tmp__table__16.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: events.st2 SIMPLE [(values__tmp__table__16)values__tmp__table__16.FieldSchema(name:tmp_values_col2, type:string, comment:), ] diff --git ql/src/test/results/clientpositive/join_cond_pushdown_unqual5.q.out ql/src/test/results/clientpositive/join_cond_pushdown_unqual5.q.out index 203010f6964329b95ddff904ac2bd13429c7ee7a..78b3bf99457095cbcc462d17ad0df6479797d39f 100644 --- ql/src/test/results/clientpositive/join_cond_pushdown_unqual5.q.out +++ ql/src/test/results/clientpositive/join_cond_pushdown_unqual5.q.out @@ -16,20 +16,26 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@rtable PREHOOK: query: insert into ltable values (1, null, 'CD5415192314304', '00071'), (2, null, 'CD5415192225530', '00071') PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@ltable POSTHOOK: query: insert into ltable values (1, null, 'CD5415192314304', '00071'), (2, null, 'CD5415192225530', '00071') POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@ltable +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: ltable.index EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: ltable.la EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: ltable.lk1 SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col3, type:string, comment:), ] POSTHOOK: Lineage: ltable.lk2 SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col4, type:string, comment:), ] PREHOOK: query: insert into rtable values (1, 'CD5415192314304', '00071'), (45, 'CD5415192314304', '00072') PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__2 PREHOOK: Output: default@rtable POSTHOOK: query: insert into rtable values (1, 'CD5415192314304', '00071'), (45, 'CD5415192314304', '00072') POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__2 POSTHOOK: Output: default@rtable +POSTHOOK: Output: default@values__tmp__table__2 POSTHOOK: Lineage: rtable.ra EXPRESSION [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: rtable.rk1 SIMPLE [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: rtable.rk2 SIMPLE [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col3, type:string, comment:), ] diff --git ql/src/test/results/clientpositive/macro_1.q.out ql/src/test/results/clientpositive/macro_1.q.out index c6e34075ee77d7d9aaec41260bd2eeb9f8f10e36..3eae2ae79af2803c20e29553759644f8de53cafb 100644 --- ql/src/test/results/clientpositive/macro_1.q.out +++ ql/src/test/results/clientpositive/macro_1.q.out @@ -26,10 +26,13 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@macro_test PREHOOK: query: insert into table macro_test values ("bb"), ("a"), ("ccc") PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@macro_test POSTHOOK: query: insert into table macro_test values ("bb"), ("a"), ("ccc") POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@macro_test +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: macro_test.x SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] PREHOOK: query: SELECT CONCAT(STRING_LEN(x), ":", STRING_LEN_PLUS_ONE(x), ":", STRING_LEN_PLUS_TWO(x)) a diff --git ql/src/test/results/clientpositive/macro_duplicate.q.out ql/src/test/results/clientpositive/macro_duplicate.q.out index 88aba21042e80f5b428c51ddf424d98815ddd699..c1684bbb7b3f5bd6c28b04a9a4e3c65cedccb7f3 100644 --- ql/src/test/results/clientpositive/macro_duplicate.q.out +++ ql/src/test/results/clientpositive/macro_duplicate.q.out @@ -12,19 +12,25 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@macro_testing PREHOOK: query: insert into table macro_testing values (1,2,3) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@macro_testing POSTHOOK: query: insert into table macro_testing values (1,2,3) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@macro_testing +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: macro_testing.a EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: macro_testing.b EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: macro_testing.c EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col3, type:string, comment:), ] PREHOOK: query: insert into table macro_testing values (4,5,6) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__2 PREHOOK: Output: default@macro_testing POSTHOOK: query: insert into table macro_testing values (4,5,6) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__2 POSTHOOK: Output: default@macro_testing +POSTHOOK: Output: default@values__tmp__table__2 POSTHOOK: Lineage: macro_testing.a EXPRESSION [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: macro_testing.b EXPRESSION [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: macro_testing.c EXPRESSION [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col3, type:string, comment:), ] diff --git ql/src/test/results/clientpositive/multi_insert_with_join.q.out ql/src/test/results/clientpositive/multi_insert_with_join.q.out index e60f2e4f56ef626ae37c67bcfc08214daabe2a6f..4bb1574875c830ca873dbc8f198c9b241b8cec52 100644 --- ql/src/test/results/clientpositive/multi_insert_with_join.q.out +++ ql/src/test/results/clientpositive/multi_insert_with_join.q.out @@ -48,19 +48,25 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@gender_summary PREHOOK: query: insert into status_updates values (1, "status_1", "2009-03-20") PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@status_updates POSTHOOK: query: insert into status_updates values (1, "status_1", "2009-03-20") POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@status_updates +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: status_updates.ds SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col3, type:string, comment:), ] POSTHOOK: Lineage: status_updates.status SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: status_updates.userid EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] PREHOOK: query: insert into profiles values (1, "school_1", 0) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__2 PREHOOK: Output: default@profiles POSTHOOK: query: insert into profiles values (1, "school_1", 0) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__2 POSTHOOK: Output: default@profiles +POSTHOOK: Output: default@values__tmp__table__2 POSTHOOK: Lineage: profiles.gender EXPRESSION [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col3, type:string, comment:), ] POSTHOOK: Lineage: profiles.school SIMPLE [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: profiles.userid EXPRESSION [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col1, type:string, comment:), ] diff --git ql/src/test/results/clientpositive/order3.q.out ql/src/test/results/clientpositive/order3.q.out index 85ee858bed330d4a5f1691bd1fa07974b9aa367f..d36fec72a975fd73c6af80ab3510ea7ad654e8a4 100644 --- ql/src/test/results/clientpositive/order3.q.out +++ ql/src/test/results/clientpositive/order3.q.out @@ -13,11 +13,14 @@ POSTHOOK: Output: default@test PREHOOK: query: insert into table test values (1, 1, 'val111'), (1, 2, 'val121'), (1, 3, 'val131'), (2, 1, 'val211'), (2, 2, 'val221'), (2, 2, 'val222'), (2, 3, 'val231'), (2, 4, 'val241'), (3, 1, 'val311'), (3, 2, 'val321'), (3, 2, 'val322'), (3, 3, 'val331'), (3, 3, 'val332'), (3, 3, 'val333'), (4, 1, 'val411') PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@test POSTHOOK: query: insert into table test values (1, 1, 'val111'), (1, 2, 'val121'), (1, 3, 'val131'), (2, 1, 'val211'), (2, 2, 'val221'), (2, 2, 'val222'), (2, 3, 'val231'), (2, 4, 'val241'), (3, 1, 'val311'), (3, 2, 'val321'), (3, 2, 'val322'), (3, 3, 'val331'), (3, 3, 'val332'), (3, 3, 'val333'), (4, 1, 'val411') POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@test +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: test.key EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: test.value1 EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: test.value2 SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col3, type:string, comment:), ] diff --git ql/src/test/results/clientpositive/parquet_join2.q.out ql/src/test/results/clientpositive/parquet_join2.q.out index 567753e751ea64c39d1b133c70124ae3e90b3f82..86643e2d33cc09428c9e88707ff203874c8e668c 100644 --- ql/src/test/results/clientpositive/parquet_join2.q.out +++ ql/src/test/results/clientpositive/parquet_join2.q.out @@ -8,10 +8,13 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@tbl1 PREHOOK: query: INSERT INTO tbl1 VALUES(1), (2) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@tbl1 POSTHOOK: query: INSERT INTO tbl1 VALUES(1), (2) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@tbl1 +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: tbl1.id EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] PREHOOK: query: CREATE TABLE tbl2(id INT, value STRING) STORED AS PARQUET PREHOOK: type: CREATETABLE @@ -23,18 +26,24 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@tbl2 PREHOOK: query: INSERT INTO tbl2 VALUES(1, 'value1') PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__2 PREHOOK: Output: default@tbl2 POSTHOOK: query: INSERT INTO tbl2 VALUES(1, 'value1') POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__2 POSTHOOK: Output: default@tbl2 +POSTHOOK: Output: default@values__tmp__table__2 POSTHOOK: Lineage: tbl2.id EXPRESSION [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: tbl2.value SIMPLE [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col2, type:string, comment:), ] PREHOOK: query: INSERT INTO tbl2 VALUES(1, 'value2') PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__3 PREHOOK: Output: default@tbl2 POSTHOOK: query: INSERT INTO tbl2 VALUES(1, 'value2') POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__3 POSTHOOK: Output: default@tbl2 +POSTHOOK: Output: default@values__tmp__table__3 POSTHOOK: Lineage: tbl2.id EXPRESSION [(values__tmp__table__3)values__tmp__table__3.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: tbl2.value SIMPLE [(values__tmp__table__3)values__tmp__table__3.FieldSchema(name:tmp_values_col2, type:string, comment:), ] PREHOOK: query: select tbl1.id, t1.value, t2.value diff --git ql/src/test/results/clientpositive/parquet_ppd_multifiles.q.out ql/src/test/results/clientpositive/parquet_ppd_multifiles.q.out index 7d4de752899bdec294d3ae09904e155ac9d372c2..bbdfef0f6ac5d49360767ece72d4a635d8154cd1 100644 --- ql/src/test/results/clientpositive/parquet_ppd_multifiles.q.out +++ ql/src/test/results/clientpositive/parquet_ppd_multifiles.q.out @@ -14,18 +14,24 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@parquet_ppd_multifiles PREHOOK: query: insert into table parquet_ppd_multifiles values('Jim', 3) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@parquet_ppd_multifiles POSTHOOK: query: insert into table parquet_ppd_multifiles values('Jim', 3) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@parquet_ppd_multifiles +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: parquet_ppd_multifiles.dec EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: parquet_ppd_multifiles.name SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] PREHOOK: query: insert into table parquet_ppd_multifiles values('Tom', 5) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__2 PREHOOK: Output: default@parquet_ppd_multifiles POSTHOOK: query: insert into table parquet_ppd_multifiles values('Tom', 5) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__2 POSTHOOK: Output: default@parquet_ppd_multifiles +POSTHOOK: Output: default@values__tmp__table__2 POSTHOOK: Lineage: parquet_ppd_multifiles.dec EXPRESSION [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: parquet_ppd_multifiles.name SIMPLE [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col1, type:string, comment:), ] PREHOOK: query: select * from parquet_ppd_multifiles where (name = 'Jim' or `dec` = 5) diff --git ql/src/test/results/clientpositive/parquet_ppd_partition.q.out ql/src/test/results/clientpositive/parquet_ppd_partition.q.out index 08f855854679ae07c0a9835267bec6a7f2b00a09..ebe26cd3d2b093705b16008b3c668433f0d723b2 100644 --- ql/src/test/results/clientpositive/parquet_ppd_partition.q.out +++ ql/src/test/results/clientpositive/parquet_ppd_partition.q.out @@ -15,10 +15,13 @@ POSTHOOK: Output: default@part1 POSTHOOK: Output: default@part1@p=p1 PREHOOK: query: INSERT INTO TABLE part1 PARTITION (p='p1') VALUES (1, 'a'), (2, 'b') PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@part1@p=p1 POSTHOOK: query: INSERT INTO TABLE part1 PARTITION (p='p1') VALUES (1, 'a'), (2, 'b') POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@part1@p=p1 +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: part1 PARTITION(p=p1).content SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: part1 PARTITION(p=p1).id EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] PREHOOK: query: SELECT * FROM part1 WHERE p='p1' diff --git ql/src/test/results/clientpositive/parquet_predicate_pushdown_2.q.out ql/src/test/results/clientpositive/parquet_predicate_pushdown_2.q.out index 6cdd0a8fb2e56dc32a6dc0dbbbb689672b007511..0c23b29112bb9291d3ed0d466c1f31627eb4fc9e 100644 --- ql/src/test/results/clientpositive/parquet_predicate_pushdown_2.q.out +++ ql/src/test/results/clientpositive/parquet_predicate_pushdown_2.q.out @@ -8,10 +8,13 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@test_parq PREHOOK: query: insert overwrite table test_parq partition (p=1) values (1, 1) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@test_parq@p=1 POSTHOOK: query: insert overwrite table test_parq partition (p=1) values (1, 1) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@test_parq@p=1 +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: test_parq PARTITION(p=1).a EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: test_parq PARTITION(p=1).b EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] PREHOOK: query: select * from test_parq where a=1 and p=1 diff --git ql/src/test/results/clientpositive/ptfgroupbyjoin.q.out ql/src/test/results/clientpositive/ptfgroupbyjoin.q.out index 8171f475f2235f31c88fe6202b5d3d8e44a07790..e93a72d330ef98535b334fc937593b83fa27eaff 100644 --- ql/src/test/results/clientpositive/ptfgroupbyjoin.q.out +++ ql/src/test/results/clientpositive/ptfgroupbyjoin.q.out @@ -16,28 +16,37 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@tlb2 PREHOOK: query: insert into table tlb1 values(100,1,'abc') PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@tlb1 POSTHOOK: query: insert into table tlb1 values(100,1,'abc') POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@tlb1 +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: tlb1.fkey EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: tlb1.id EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: tlb1.val SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col3, type:string, comment:), ] PREHOOK: query: insert into table tlb1 values(200,1,'efg') PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__2 PREHOOK: Output: default@tlb1 POSTHOOK: query: insert into table tlb1 values(200,1,'efg') POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__2 POSTHOOK: Output: default@tlb1 +POSTHOOK: Output: default@values__tmp__table__2 POSTHOOK: Lineage: tlb1.fkey EXPRESSION [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: tlb1.id EXPRESSION [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: tlb1.val SIMPLE [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col3, type:string, comment:), ] PREHOOK: query: insert into table tlb2 values(1, 'key1') PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__3 PREHOOK: Output: default@tlb2 POSTHOOK: query: insert into table tlb2 values(1, 'key1') POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__3 POSTHOOK: Output: default@tlb2 +POSTHOOK: Output: default@values__tmp__table__3 POSTHOOK: Lineage: tlb2.fid EXPRESSION [(values__tmp__table__3)values__tmp__table__3.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: tlb2.name SIMPLE [(values__tmp__table__3)values__tmp__table__3.FieldSchema(name:tmp_values_col2, type:string, comment:), ] PREHOOK: query: explain diff --git ql/src/test/results/clientpositive/smb_join_partition_key.q.out ql/src/test/results/clientpositive/smb_join_partition_key.q.out index 7fa9d2eab37bedfe85f3cf3c2c49e5f8abe82dc1..9160fdd448add00a241798f76ffe39fb00175dea 100644 --- ql/src/test/results/clientpositive/smb_join_partition_key.q.out +++ ql/src/test/results/clientpositive/smb_join_partition_key.q.out @@ -8,18 +8,24 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@data_table PREHOOK: query: insert into table data_table values(1, 'one') PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@data_table POSTHOOK: query: insert into table data_table values(1, 'one') POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@data_table +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: data_table.key EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: data_table.value SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] PREHOOK: query: insert into table data_table values(2, 'two') PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__2 PREHOOK: Output: default@data_table POSTHOOK: query: insert into table data_table values(2, 'two') POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__2 POSTHOOK: Output: default@data_table +POSTHOOK: Output: default@values__tmp__table__2 POSTHOOK: Lineage: data_table.key EXPRESSION [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: data_table.value SIMPLE [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col2, type:string, comment:), ] PREHOOK: query: CREATE TABLE smb_table (key INT, value STRING) CLUSTERED BY (key) diff --git ql/src/test/results/clientpositive/spark/constprog_semijoin.q.out ql/src/test/results/clientpositive/spark/constprog_semijoin.q.out index d116f6acd84b1b1e17580711e4d6cb16ecfe0dc4..6573ec16f07745ac2c1f3cea6aaff3a6ce9068b9 100644 --- ql/src/test/results/clientpositive/spark/constprog_semijoin.q.out +++ ql/src/test/results/clientpositive/spark/constprog_semijoin.q.out @@ -8,10 +8,15 @@ 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: default@Values__Tmp__Table__1 +PREHOOK: Output: default@Values__Tmp__Table__1 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: default@Values__Tmp__Table__1 +POSTHOOK: Output: default@Values__Tmp__Table__1 POSTHOOK: Output: default@table1 +POSTHOOK: Output: default@values__tmp__table__1 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:), ] @@ -26,10 +31,15 @@ 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: default@Values__Tmp__Table__2 +PREHOOK: Output: default@Values__Tmp__Table__2 PREHOOK: Output: default@table2 POSTHOOK: query: insert into table2 (id, val2) values (1, 't2val201'), (2, 't2val202'), (3, 't2val203') POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__2 +POSTHOOK: Output: default@Values__Tmp__Table__2 POSTHOOK: Output: default@table2 +POSTHOOK: Output: default@values__tmp__table__2 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:), ] PREHOOK: query: create table table3 (id int) @@ -42,10 +52,15 @@ 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: default@Values__Tmp__Table__3 +PREHOOK: Output: default@Values__Tmp__Table__3 PREHOOK: Output: default@table3 POSTHOOK: query: insert into table3 (id) values (100), (100), (101), (102), (103) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__3 +POSTHOOK: Output: default@Values__Tmp__Table__3 POSTHOOK: Output: default@table3 +POSTHOOK: Output: default@values__tmp__table__3 POSTHOOK: Lineage: table3.id EXPRESSION [(values__tmp__table__3)values__tmp__table__3.FieldSchema(name:tmp_values_col1, type:string, comment:), ] 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 diff --git ql/src/test/results/clientpositive/spark/explaindenpendencydiffengs.q.out ql/src/test/results/clientpositive/spark/explaindenpendencydiffengs.q.out index bf1c78135eef4cf3762894e35d8b590b748f2b16..76ffdaa6f7f67c9004452e33297e0745667d86d2 100644 --- ql/src/test/results/clientpositive/spark/explaindenpendencydiffengs.q.out +++ ql/src/test/results/clientpositive/spark/explaindenpendencydiffengs.q.out @@ -12,10 +12,15 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@dependtest PREHOOK: query: insert into table dependtest partition (b=1) values ("hello") PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 +PREHOOK: Output: default@Values__Tmp__Table__1 PREHOOK: Output: default@dependtest@b=1 POSTHOOK: query: insert into table dependtest partition (b=1) values ("hello") POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 +POSTHOOK: Output: default@Values__Tmp__Table__1 POSTHOOK: Output: default@dependtest@b=1 +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: dependtest PARTITION(b=1).a SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] PREHOOK: query: create view viewtest as select * from dependtest where b = 1 PREHOOK: type: CREATEVIEW diff --git ql/src/test/results/clientpositive/spark/multi_insert_with_join.q.out ql/src/test/results/clientpositive/spark/multi_insert_with_join.q.out index e60f2e4f56ef626ae37c67bcfc08214daabe2a6f..269a79b7e7b075423a3be8cb401d91c77973b21b 100644 --- ql/src/test/results/clientpositive/spark/multi_insert_with_join.q.out +++ ql/src/test/results/clientpositive/spark/multi_insert_with_join.q.out @@ -48,19 +48,29 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@gender_summary PREHOOK: query: insert into status_updates values (1, "status_1", "2009-03-20") PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 +PREHOOK: Output: default@Values__Tmp__Table__1 PREHOOK: Output: default@status_updates POSTHOOK: query: insert into status_updates values (1, "status_1", "2009-03-20") POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 +POSTHOOK: Output: default@Values__Tmp__Table__1 POSTHOOK: Output: default@status_updates +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: status_updates.ds SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col3, type:string, comment:), ] POSTHOOK: Lineage: status_updates.status SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: status_updates.userid EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] PREHOOK: query: insert into profiles values (1, "school_1", 0) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__2 +PREHOOK: Output: default@Values__Tmp__Table__2 PREHOOK: Output: default@profiles POSTHOOK: query: insert into profiles values (1, "school_1", 0) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__2 +POSTHOOK: Output: default@Values__Tmp__Table__2 POSTHOOK: Output: default@profiles +POSTHOOK: Output: default@values__tmp__table__2 POSTHOOK: Lineage: profiles.gender EXPRESSION [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col3, type:string, comment:), ] POSTHOOK: Lineage: profiles.school SIMPLE [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: profiles.userid EXPRESSION [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col1, type:string, comment:), ] diff --git ql/src/test/results/clientpositive/transform3.q.out ql/src/test/results/clientpositive/transform3.q.out index 5f93ed8127009461c2ce182bea6b4ae9d6a2c9b1..af93b15e4ac95958f638fdf3f2f60fb6e1d91cf7 100644 --- ql/src/test/results/clientpositive/transform3.q.out +++ ql/src/test/results/clientpositive/transform3.q.out @@ -8,10 +8,13 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@transform3_t1 PREHOOK: query: INSERT OVERWRITE TABLE transform3_t1 VALUES('aaaa') PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@transform3_t1 POSTHOOK: query: INSERT OVERWRITE TABLE transform3_t1 VALUES('aaaa') POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@transform3_t1 +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: transform3_t1.col SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] PREHOOK: query: SELECT t.newCol FROM ( SELECT TRANSFORM(col) USING 'cat' AS (NewCol string) FROM transform3_t1 diff --git ql/src/test/results/clientpositive/udf_folder_constants.q.out ql/src/test/results/clientpositive/udf_folder_constants.q.out index c27c59c79b0be2ad545609340550caf61fb99b85..6ff085f86adff87fb914784e9e024e61dac16e90 100644 --- ql/src/test/results/clientpositive/udf_folder_constants.q.out +++ ql/src/test/results/clientpositive/udf_folder_constants.q.out @@ -24,18 +24,24 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@udf_tb2 PREHOOK: query: insert into udf_tb1 values(2001, 11) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@udf_tb1 POSTHOOK: query: insert into udf_tb1 values(2001, 11) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@udf_tb1 +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: udf_tb1.month EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: udf_tb1.year EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] PREHOOK: query: insert into udf_tb2 values(11) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__2 PREHOOK: Output: default@udf_tb2 POSTHOOK: query: insert into udf_tb2 values(11) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__2 POSTHOOK: Output: default@udf_tb2 +POSTHOOK: Output: default@values__tmp__table__2 POSTHOOK: Lineage: udf_tb2.month EXPRESSION [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col1, type:string, comment:), ] PREHOOK: query: explain select unix_timestamp(concat(a.year, '-01-01 00:00:00')) from (select * from udf_tb1 where year=2001) a join udf_tb2 b on (a.month=b.month) diff --git ql/src/test/results/clientpositive/unionall_unbalancedppd.q.out ql/src/test/results/clientpositive/unionall_unbalancedppd.q.out index 625063a5128694e50622434ef079d265ea50f7c5..c59e686f093c3326d3d0bb711d101d3ed6a2bdb7 100644 --- ql/src/test/results/clientpositive/unionall_unbalancedppd.q.out +++ ql/src/test/results/clientpositive/unionall_unbalancedppd.q.out @@ -144,33 +144,45 @@ POSTHOOK: Input: default@union_all_bug_test_2 #### A masked pattern was here #### PREHOOK: query: insert into table union_all_bug_test_1 values (1,1) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@union_all_bug_test_1 POSTHOOK: query: insert into table union_all_bug_test_1 values (1,1) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@union_all_bug_test_1 +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: union_all_bug_test_1.f1 EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: union_all_bug_test_1.f2 EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] PREHOOK: query: insert into table union_all_bug_test_2 values (1) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__2 PREHOOK: Output: default@union_all_bug_test_2 POSTHOOK: query: insert into table union_all_bug_test_2 values (1) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__2 POSTHOOK: Output: default@union_all_bug_test_2 +POSTHOOK: Output: default@values__tmp__table__2 POSTHOOK: Lineage: union_all_bug_test_2.f1 EXPRESSION [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col1, type:string, comment:), ] PREHOOK: query: insert into table union_all_bug_test_1 values (0,0) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__3 PREHOOK: Output: default@union_all_bug_test_1 POSTHOOK: query: insert into table union_all_bug_test_1 values (0,0) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__3 POSTHOOK: Output: default@union_all_bug_test_1 +POSTHOOK: Output: default@values__tmp__table__3 POSTHOOK: Lineage: union_all_bug_test_1.f1 EXPRESSION [(values__tmp__table__3)values__tmp__table__3.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: union_all_bug_test_1.f2 EXPRESSION [(values__tmp__table__3)values__tmp__table__3.FieldSchema(name:tmp_values_col2, type:string, comment:), ] PREHOOK: query: insert into table union_all_bug_test_2 values (0) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__4 PREHOOK: Output: default@union_all_bug_test_2 POSTHOOK: query: insert into table union_all_bug_test_2 values (0) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__4 POSTHOOK: Output: default@union_all_bug_test_2 +POSTHOOK: Output: default@values__tmp__table__4 POSTHOOK: Lineage: union_all_bug_test_2.f1 EXPRESSION [(values__tmp__table__4)values__tmp__table__4.FieldSchema(name:tmp_values_col1, type:string, comment:), ] PREHOOK: query: SELECT f1 FROM ( diff --git ql/src/test/results/clientpositive/update_after_multiple_inserts.q.out ql/src/test/results/clientpositive/update_after_multiple_inserts.q.out index 36f2aa48d2b122ab3757bc2b057bdcee27832cce..77cbfe7e2bed1e258ac7742f46130dbea371f63e 100644 --- ql/src/test/results/clientpositive/update_after_multiple_inserts.q.out +++ ql/src/test/results/clientpositive/update_after_multiple_inserts.q.out @@ -14,12 +14,15 @@ PREHOOK: query: insert into table acid_uami values (1, 109.23, 'mary had a little lamb'), (6553, 923.19, 'its fleece was white as snow') PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@acid_uami POSTHOOK: query: insert into table acid_uami values (1, 109.23, 'mary had a little lamb'), (6553, 923.19, 'its fleece was white as snow') POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@acid_uami +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: acid_uami.de EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: acid_uami.i EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: acid_uami.vc EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col3, type:string, comment:), ] @@ -27,12 +30,15 @@ PREHOOK: query: insert into table acid_uami values (10, 119.23, 'and everywhere that mary went'), (65530, 823.19, 'the lamb was sure to go') PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__2 PREHOOK: Output: default@acid_uami POSTHOOK: query: insert into table acid_uami values (10, 119.23, 'and everywhere that mary went'), (65530, 823.19, 'the lamb was sure to go') POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__2 POSTHOOK: Output: default@acid_uami +POSTHOOK: Output: default@values__tmp__table__2 POSTHOOK: Lineage: acid_uami.de EXPRESSION [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: acid_uami.i EXPRESSION [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: acid_uami.vc EXPRESSION [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col3, type:string, comment:), ] diff --git ql/src/test/results/clientpositive/vector_aggregate_without_gby.q.out ql/src/test/results/clientpositive/vector_aggregate_without_gby.q.out index 79028b4b6eddcb66a0ea8cb45b0482b2fe87e4d6..b3e55ef16d249b562fbe7cfb76db21819a7d48d3 100644 --- ql/src/test/results/clientpositive/vector_aggregate_without_gby.q.out +++ ql/src/test/results/clientpositive/vector_aggregate_without_gby.q.out @@ -16,6 +16,7 @@ values (6,20150314, '2015-03-14'), (7,20150404, '2015-04-04') PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@testvec POSTHOOK: query: insert into table testvec values @@ -27,7 +28,9 @@ values (6,20150314, '2015-03-14'), (7,20150404, '2015-04-04') POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@testvec +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: testvec.dt EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: testvec.greg_dt SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col3, type:string, comment:), ] POSTHOOK: Lineage: testvec.id EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] diff --git ql/src/test/results/clientpositive/vector_char_cast.q.out ql/src/test/results/clientpositive/vector_char_cast.q.out index c836dd80fd95848b8953775f239fcc4b60f2893b..3ba27b560dc38a47d5812fc3b41e8d3b486579ac 100644 --- ql/src/test/results/clientpositive/vector_char_cast.q.out +++ ql/src/test/results/clientpositive/vector_char_cast.q.out @@ -8,10 +8,13 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@s1 PREHOOK: query: insert into table s1 values (1000),(1001),(1002),(1003),(1000) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@s1 POSTHOOK: query: insert into table s1 values (1000),(1001),(1002),(1003),(1000) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@s1 +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: s1.id EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] PREHOOK: query: select count(1) from s1 where cast(id as char(4))='1000' PREHOOK: type: QUERY diff --git ql/src/test/results/clientpositive/vector_coalesce_2.q.out ql/src/test/results/clientpositive/vector_coalesce_2.q.out index 9c40d2ce9ae286dacace755c446082e06b9264a0..21a56d6b466ddf48afd306f9bdf96ac42ccea2c9 100644 --- ql/src/test/results/clientpositive/vector_coalesce_2.q.out +++ ql/src/test/results/clientpositive/vector_coalesce_2.q.out @@ -8,10 +8,13 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@str_str_orc PREHOOK: query: insert into table str_str_orc values (null, "X"), ("0", "X"), ("1", "X"), (null, "y") PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@str_str_orc POSTHOOK: query: insert into table str_str_orc values (null, "X"), ("0", "X"), ("1", "X"), (null, "y") POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@str_str_orc +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: str_str_orc.str1 SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] POSTHOOK: Lineage: str_str_orc.str2 SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col2, type:string, comment:), ] PREHOOK: query: EXPLAIN VECTORIZATION EXPRESSION diff --git ql/src/test/results/clientpositive/vector_decimal_round.q.out ql/src/test/results/clientpositive/vector_decimal_round.q.out index dd32a510bc676e7cd82510e3a08bba4cd77b9860..06de68a635c40d9fa4b6a3a8e8a76462228081c9 100644 --- ql/src/test/results/clientpositive/vector_decimal_round.q.out +++ ql/src/test/results/clientpositive/vector_decimal_round.q.out @@ -14,10 +14,13 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@decimal_tbl_txt PREHOOK: query: insert into table decimal_tbl_txt values(101) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@decimal_tbl_txt POSTHOOK: query: insert into table decimal_tbl_txt values(101) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@decimal_tbl_txt +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: decimal_tbl_txt.dec EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] PREHOOK: query: select * from decimal_tbl_txt PREHOOK: type: QUERY @@ -222,10 +225,13 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@decimal_tbl_rc PREHOOK: query: insert into table decimal_tbl_rc values(101) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__2 PREHOOK: Output: default@decimal_tbl_rc POSTHOOK: query: insert into table decimal_tbl_rc values(101) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__2 POSTHOOK: Output: default@decimal_tbl_rc +POSTHOOK: Output: default@values__tmp__table__2 POSTHOOK: Lineage: decimal_tbl_rc.dec EXPRESSION [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col1, type:string, comment:), ] PREHOOK: query: select * from decimal_tbl_rc PREHOOK: type: QUERY @@ -430,10 +436,13 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@decimal_tbl_orc PREHOOK: query: insert into table decimal_tbl_orc values(101) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__3 PREHOOK: Output: default@decimal_tbl_orc POSTHOOK: query: insert into table decimal_tbl_orc values(101) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__3 POSTHOOK: Output: default@decimal_tbl_orc +POSTHOOK: Output: default@values__tmp__table__3 POSTHOOK: Lineage: decimal_tbl_orc.dec EXPRESSION [(values__tmp__table__3)values__tmp__table__3.FieldSchema(name:tmp_values_col1, type:string, comment:), ] PREHOOK: query: select * from decimal_tbl_orc PREHOOK: type: QUERY diff --git ql/src/test/results/clientpositive/vector_decimal_round_2.q.out ql/src/test/results/clientpositive/vector_decimal_round_2.q.out index f6121a2aefb3cb5dcb2c5aa8fb46aca3d0d78978..85b9cf745957064a1da9ba39e9e4db2a8346d7d8 100644 --- ql/src/test/results/clientpositive/vector_decimal_round_2.q.out +++ ql/src/test/results/clientpositive/vector_decimal_round_2.q.out @@ -10,10 +10,13 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@decimal_tbl_1_orc PREHOOK: query: insert into table decimal_tbl_1_orc values(55555) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__1 PREHOOK: Output: default@decimal_tbl_1_orc POSTHOOK: query: insert into table decimal_tbl_1_orc values(55555) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__1 POSTHOOK: Output: default@decimal_tbl_1_orc +POSTHOOK: Output: default@values__tmp__table__1 POSTHOOK: Lineage: decimal_tbl_1_orc.dec EXPRESSION [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] PREHOOK: query: select * from decimal_tbl_1_orc PREHOOK: type: QUERY @@ -143,10 +146,13 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@decimal_tbl_2_orc PREHOOK: query: insert into table decimal_tbl_2_orc values(125.315, -125.315) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__2 PREHOOK: Output: default@decimal_tbl_2_orc POSTHOOK: query: insert into table decimal_tbl_2_orc values(125.315, -125.315) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__2 POSTHOOK: Output: default@decimal_tbl_2_orc +POSTHOOK: Output: default@values__tmp__table__2 POSTHOOK: Lineage: decimal_tbl_2_orc.neg EXPRESSION [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: decimal_tbl_2_orc.pos EXPRESSION [(values__tmp__table__2)values__tmp__table__2.FieldSchema(name:tmp_values_col1, type:string, comment:), ] PREHOOK: query: select * from decimal_tbl_2_orc @@ -289,10 +295,13 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@decimal_tbl_3_orc PREHOOK: query: insert into table decimal_tbl_3_orc values(3.141592653589793) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__3 PREHOOK: Output: default@decimal_tbl_3_orc POSTHOOK: query: insert into table decimal_tbl_3_orc values(3.141592653589793) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__3 POSTHOOK: Output: default@decimal_tbl_3_orc +POSTHOOK: Output: default@values__tmp__table__3 POSTHOOK: Lineage: decimal_tbl_3_orc.dec EXPRESSION [(values__tmp__table__3)values__tmp__table__3.FieldSchema(name:tmp_values_col1, type:string, comment:), ] PREHOOK: query: select * from decimal_tbl_3_orc PREHOOK: type: QUERY @@ -478,10 +487,13 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@decimal_tbl_4_orc PREHOOK: query: insert into table decimal_tbl_4_orc values(1809242.3151111344, -1809242.3151111344) PREHOOK: type: QUERY +PREHOOK: Input: default@Values__Tmp__Table__4 PREHOOK: Output: default@decimal_tbl_4_orc POSTHOOK: query: insert into table decimal_tbl_4_orc values(1809242.3151111344, -1809242.3151111344) POSTHOOK: type: QUERY +POSTHOOK: Input: default@Values__Tmp__Table__4 POSTHOOK: Output: default@decimal_tbl_4_orc +POSTHOOK: Output: default@values__tmp__table__4 POSTHOOK: Lineage: decimal_tbl_4_orc.neg EXPRESSION [(values__tmp__table__4)values__tmp__table__4.FieldSchema(name:tmp_values_col2, type:string, comment:), ] POSTHOOK: Lineage: decimal_tbl_4_orc.pos EXPRESSION [(values__tmp__table__4)values__tmp__table__4.FieldSchema(name:tmp_values_col1, type:string, comment:), ] PREHOOK: query: select * from decimal_tbl_4_orc