diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/OctetLength.java ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/OctetLength.java index 3d85772..3b41ed4 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/OctetLength.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/OctetLength.java @@ -25,8 +25,8 @@ public class OctetLength extends VectorExpression { private static final long serialVersionUID = 1L; - private transient int colNum; - private transient int outputColumn; + private int colNum; + private int outputColumn; public OctetLength(int colNum, int outputColumn) { this(); diff --git ql/src/test/queries/clientpositive/vector_udf_character_length.q ql/src/test/queries/clientpositive/vector_udf_character_length.q index 5e6a640..19a5260 100644 --- ql/src/test/queries/clientpositive/vector_udf_character_length.q +++ ql/src/test/queries/clientpositive/vector_udf_character_length.q @@ -18,12 +18,14 @@ DROP TABLE dest1; CREATE TABLE dest1(name STRING) STORED AS TEXTFILE; LOAD DATA LOCAL INPATH '../../data/files/kv4.txt' INTO TABLE dest1; INSERT INTO dest1 VALUES(NULL); +CREATE TABLE dest2 STORED AS ORC AS SELECT * FROM dest1; -EXPLAIN SELECT character_length(dest1.name) FROM dest1; +EXPLAIN SELECT character_length(dest2.name) FROM dest2; -- SORT_BEFORE_DIFF -SELECT character_length(dest1.name) FROM dest1; +SELECT character_length(dest2.name) FROM dest2; -EXPLAIN SELECT char_length(dest1.name) FROM dest1; +EXPLAIN SELECT char_length(dest2.name) FROM dest2; -- SORT_BEFORE_DIFF -SELECT char_length(dest1.name) FROM dest1; +SELECT char_length(dest2.name) FROM dest2; DROP TABLE dest1; +DROP TABLE dest2; diff --git ql/src/test/queries/clientpositive/vector_udf_octet_length.q ql/src/test/queries/clientpositive/vector_udf_octet_length.q index b8c8910..06a4985 100644 --- ql/src/test/queries/clientpositive/vector_udf_octet_length.q +++ ql/src/test/queries/clientpositive/vector_udf_octet_length.q @@ -15,7 +15,9 @@ DROP TABLE dest1; CREATE TABLE dest1(name STRING) STORED AS TEXTFILE; LOAD DATA LOCAL INPATH '../../data/files/kv4.txt' INTO TABLE dest1; INSERT INTO dest1 VALUES(NULL); -EXPLAIN SELECT octet_length(dest1.name) FROM dest1; +CREATE TABLE dest2 STORED AS ORC AS SELECT * FROM dest1; +EXPLAIN SELECT octet_length(dest2.name) FROM dest2; -- SORT_BEFORE_DIFF -SELECT octet_length(dest1.name) FROM dest1; +SELECT octet_length(dest2.name) FROM dest2; DROP TABLE dest1; +DROP TABLE dest2; diff --git ql/src/test/results/clientpositive/llap/vector_udf_character_length.q.out ql/src/test/results/clientpositive/llap/vector_udf_character_length.q.out index a03fb50..b26db2d 100644 --- ql/src/test/results/clientpositive/llap/vector_udf_character_length.q.out +++ ql/src/test/results/clientpositive/llap/vector_udf_character_length.q.out @@ -162,9 +162,20 @@ POSTHOOK: query: INSERT INTO dest1 VALUES(NULL) POSTHOOK: type: QUERY POSTHOOK: Output: default@dest1 POSTHOOK: Lineage: dest1.name SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] -PREHOOK: query: EXPLAIN SELECT character_length(dest1.name) FROM dest1 +PREHOOK: query: CREATE TABLE dest2 STORED AS ORC AS SELECT * FROM dest1 +PREHOOK: type: CREATETABLE_AS_SELECT +PREHOOK: Input: default@dest1 +PREHOOK: Output: database:default +PREHOOK: Output: default@dest2 +POSTHOOK: query: CREATE TABLE dest2 STORED AS ORC AS SELECT * FROM dest1 +POSTHOOK: type: CREATETABLE_AS_SELECT +POSTHOOK: Input: default@dest1 +POSTHOOK: Output: database:default +POSTHOOK: Output: default@dest2 +POSTHOOK: Lineage: dest2.name SIMPLE [(dest1)dest1.FieldSchema(name:name, type:string, comment:null), ] +PREHOOK: query: EXPLAIN SELECT character_length(dest2.name) FROM dest2 PREHOOK: type: QUERY -POSTHOOK: query: EXPLAIN SELECT character_length(dest1.name) FROM dest1 +POSTHOOK: query: EXPLAIN SELECT character_length(dest2.name) FROM dest2 POSTHOOK: type: QUERY STAGE DEPENDENCIES: Stage-1 is a root stage @@ -178,21 +189,21 @@ STAGE PLANS: Map 1 Map Operator Tree: TableScan - alias: dest1 - Statistics: Num rows: 1 Data size: 9 Basic stats: COMPLETE Column stats: NONE + alias: dest2 + Statistics: Num rows: 2 Data size: 90 Basic stats: COMPLETE Column stats: NONE Select Operator expressions: character_length(name) (type: int) outputColumnNames: _col0 - Statistics: Num rows: 1 Data size: 9 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 2 Data size: 90 Basic stats: COMPLETE Column stats: NONE File Output Operator compressed: false - Statistics: Num rows: 1 Data size: 9 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 2 Data size: 90 Basic stats: COMPLETE Column stats: NONE table: input format: org.apache.hadoop.mapred.SequenceFileInputFormat output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe - Execution mode: llap - LLAP IO: no inputs + Execution mode: vectorized, llap + LLAP IO: all inputs Stage: Stage-0 Fetch Operator @@ -200,19 +211,19 @@ STAGE PLANS: Processor Tree: ListSink -PREHOOK: query: SELECT character_length(dest1.name) FROM dest1 +PREHOOK: query: SELECT character_length(dest2.name) FROM dest2 PREHOOK: type: QUERY -PREHOOK: Input: default@dest1 +PREHOOK: Input: default@dest2 #### A masked pattern was here #### -POSTHOOK: query: SELECT character_length(dest1.name) FROM dest1 +POSTHOOK: query: SELECT character_length(dest2.name) FROM dest2 POSTHOOK: type: QUERY -POSTHOOK: Input: default@dest1 +POSTHOOK: Input: default@dest2 #### A masked pattern was here #### 2 NULL -PREHOOK: query: EXPLAIN SELECT char_length(dest1.name) FROM dest1 +PREHOOK: query: EXPLAIN SELECT char_length(dest2.name) FROM dest2 PREHOOK: type: QUERY -POSTHOOK: query: EXPLAIN SELECT char_length(dest1.name) FROM dest1 +POSTHOOK: query: EXPLAIN SELECT char_length(dest2.name) FROM dest2 POSTHOOK: type: QUERY STAGE DEPENDENCIES: Stage-1 is a root stage @@ -226,21 +237,21 @@ STAGE PLANS: Map 1 Map Operator Tree: TableScan - alias: dest1 - Statistics: Num rows: 1 Data size: 9 Basic stats: COMPLETE Column stats: NONE + alias: dest2 + Statistics: Num rows: 2 Data size: 90 Basic stats: COMPLETE Column stats: NONE Select Operator expressions: character_length(name) (type: int) outputColumnNames: _col0 - Statistics: Num rows: 1 Data size: 9 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 2 Data size: 90 Basic stats: COMPLETE Column stats: NONE File Output Operator compressed: false - Statistics: Num rows: 1 Data size: 9 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 2 Data size: 90 Basic stats: COMPLETE Column stats: NONE table: input format: org.apache.hadoop.mapred.SequenceFileInputFormat output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe - Execution mode: llap - LLAP IO: no inputs + Execution mode: vectorized, llap + LLAP IO: all inputs Stage: Stage-0 Fetch Operator @@ -248,13 +259,13 @@ STAGE PLANS: Processor Tree: ListSink -PREHOOK: query: SELECT char_length(dest1.name) FROM dest1 +PREHOOK: query: SELECT char_length(dest2.name) FROM dest2 PREHOOK: type: QUERY -PREHOOK: Input: default@dest1 +PREHOOK: Input: default@dest2 #### A masked pattern was here #### -POSTHOOK: query: SELECT char_length(dest1.name) FROM dest1 +POSTHOOK: query: SELECT char_length(dest2.name) FROM dest2 POSTHOOK: type: QUERY -POSTHOOK: Input: default@dest1 +POSTHOOK: Input: default@dest2 #### A masked pattern was here #### 2 NULL @@ -266,3 +277,11 @@ POSTHOOK: query: DROP TABLE dest1 POSTHOOK: type: DROPTABLE POSTHOOK: Input: default@dest1 POSTHOOK: Output: default@dest1 +PREHOOK: query: DROP TABLE dest2 +PREHOOK: type: DROPTABLE +PREHOOK: Input: default@dest2 +PREHOOK: Output: default@dest2 +POSTHOOK: query: DROP TABLE dest2 +POSTHOOK: type: DROPTABLE +POSTHOOK: Input: default@dest2 +POSTHOOK: Output: default@dest2 diff --git ql/src/test/results/clientpositive/llap/vector_udf_octet_length.q.out ql/src/test/results/clientpositive/llap/vector_udf_octet_length.q.out index c735f1a..10ace12 100644 --- ql/src/test/results/clientpositive/llap/vector_udf_octet_length.q.out +++ ql/src/test/results/clientpositive/llap/vector_udf_octet_length.q.out @@ -145,9 +145,20 @@ POSTHOOK: query: INSERT INTO dest1 VALUES(NULL) POSTHOOK: type: QUERY POSTHOOK: Output: default@dest1 POSTHOOK: Lineage: dest1.name SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] -PREHOOK: query: EXPLAIN SELECT octet_length(dest1.name) FROM dest1 +PREHOOK: query: CREATE TABLE dest2 STORED AS ORC AS SELECT * FROM dest1 +PREHOOK: type: CREATETABLE_AS_SELECT +PREHOOK: Input: default@dest1 +PREHOOK: Output: database:default +PREHOOK: Output: default@dest2 +POSTHOOK: query: CREATE TABLE dest2 STORED AS ORC AS SELECT * FROM dest1 +POSTHOOK: type: CREATETABLE_AS_SELECT +POSTHOOK: Input: default@dest1 +POSTHOOK: Output: database:default +POSTHOOK: Output: default@dest2 +POSTHOOK: Lineage: dest2.name SIMPLE [(dest1)dest1.FieldSchema(name:name, type:string, comment:null), ] +PREHOOK: query: EXPLAIN SELECT octet_length(dest2.name) FROM dest2 PREHOOK: type: QUERY -POSTHOOK: query: EXPLAIN SELECT octet_length(dest1.name) FROM dest1 +POSTHOOK: query: EXPLAIN SELECT octet_length(dest2.name) FROM dest2 POSTHOOK: type: QUERY STAGE DEPENDENCIES: Stage-1 is a root stage @@ -161,21 +172,21 @@ STAGE PLANS: Map 1 Map Operator Tree: TableScan - alias: dest1 - Statistics: Num rows: 1 Data size: 9 Basic stats: COMPLETE Column stats: NONE + alias: dest2 + Statistics: Num rows: 2 Data size: 90 Basic stats: COMPLETE Column stats: NONE Select Operator expressions: octet_length(name) (type: int) outputColumnNames: _col0 - Statistics: Num rows: 1 Data size: 9 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 2 Data size: 90 Basic stats: COMPLETE Column stats: NONE File Output Operator compressed: false - Statistics: Num rows: 1 Data size: 9 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 2 Data size: 90 Basic stats: COMPLETE Column stats: NONE table: input format: org.apache.hadoop.mapred.SequenceFileInputFormat output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe - Execution mode: llap - LLAP IO: no inputs + Execution mode: vectorized, llap + LLAP IO: all inputs Stage: Stage-0 Fetch Operator @@ -183,13 +194,13 @@ STAGE PLANS: Processor Tree: ListSink -PREHOOK: query: SELECT octet_length(dest1.name) FROM dest1 +PREHOOK: query: SELECT octet_length(dest2.name) FROM dest2 PREHOOK: type: QUERY -PREHOOK: Input: default@dest1 +PREHOOK: Input: default@dest2 #### A masked pattern was here #### -POSTHOOK: query: SELECT octet_length(dest1.name) FROM dest1 +POSTHOOK: query: SELECT octet_length(dest2.name) FROM dest2 POSTHOOK: type: QUERY -POSTHOOK: Input: default@dest1 +POSTHOOK: Input: default@dest2 #### A masked pattern was here #### 6 NULL @@ -201,3 +212,11 @@ POSTHOOK: query: DROP TABLE dest1 POSTHOOK: type: DROPTABLE POSTHOOK: Input: default@dest1 POSTHOOK: Output: default@dest1 +PREHOOK: query: DROP TABLE dest2 +PREHOOK: type: DROPTABLE +PREHOOK: Input: default@dest2 +PREHOOK: Output: default@dest2 +POSTHOOK: query: DROP TABLE dest2 +POSTHOOK: type: DROPTABLE +POSTHOOK: Input: default@dest2 +POSTHOOK: Output: default@dest2 diff --git ql/src/test/results/clientpositive/vector_udf_character_length.q.out ql/src/test/results/clientpositive/vector_udf_character_length.q.out index 43003ea..558bfc8 100644 --- ql/src/test/results/clientpositive/vector_udf_character_length.q.out +++ ql/src/test/results/clientpositive/vector_udf_character_length.q.out @@ -197,9 +197,20 @@ POSTHOOK: query: INSERT INTO dest1 VALUES(NULL) POSTHOOK: type: QUERY POSTHOOK: Output: default@dest1 POSTHOOK: Lineage: dest1.name SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] -PREHOOK: query: EXPLAIN SELECT character_length(dest1.name) FROM dest1 +PREHOOK: query: CREATE TABLE dest2 STORED AS ORC AS SELECT * FROM dest1 +PREHOOK: type: CREATETABLE_AS_SELECT +PREHOOK: Input: default@dest1 +PREHOOK: Output: database:default +PREHOOK: Output: default@dest2 +POSTHOOK: query: CREATE TABLE dest2 STORED AS ORC AS SELECT * FROM dest1 +POSTHOOK: type: CREATETABLE_AS_SELECT +POSTHOOK: Input: default@dest1 +POSTHOOK: Output: database:default +POSTHOOK: Output: default@dest2 +POSTHOOK: Lineage: dest2.name SIMPLE [(dest1)dest1.FieldSchema(name:name, type:string, comment:null), ] +PREHOOK: query: EXPLAIN SELECT character_length(dest2.name) FROM dest2 PREHOOK: type: QUERY -POSTHOOK: query: EXPLAIN SELECT character_length(dest1.name) FROM dest1 +POSTHOOK: query: EXPLAIN SELECT character_length(dest2.name) FROM dest2 POSTHOOK: type: QUERY STAGE DEPENDENCIES: Stage-1 is a root stage @@ -210,19 +221,20 @@ STAGE PLANS: Map Reduce Map Operator Tree: TableScan - alias: dest1 - Statistics: Num rows: 1 Data size: 9 Basic stats: COMPLETE Column stats: NONE + alias: dest2 + Statistics: Num rows: 2 Data size: 90 Basic stats: COMPLETE Column stats: NONE Select Operator expressions: character_length(name) (type: int) outputColumnNames: _col0 - Statistics: Num rows: 1 Data size: 9 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 2 Data size: 90 Basic stats: COMPLETE Column stats: NONE File Output Operator compressed: false - Statistics: Num rows: 1 Data size: 9 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 2 Data size: 90 Basic stats: COMPLETE Column stats: NONE table: input format: org.apache.hadoop.mapred.SequenceFileInputFormat output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe + Execution mode: vectorized Stage: Stage-0 Fetch Operator @@ -230,19 +242,19 @@ STAGE PLANS: Processor Tree: ListSink -PREHOOK: query: SELECT character_length(dest1.name) FROM dest1 +PREHOOK: query: SELECT character_length(dest2.name) FROM dest2 PREHOOK: type: QUERY -PREHOOK: Input: default@dest1 +PREHOOK: Input: default@dest2 #### A masked pattern was here #### -POSTHOOK: query: SELECT character_length(dest1.name) FROM dest1 +POSTHOOK: query: SELECT character_length(dest2.name) FROM dest2 POSTHOOK: type: QUERY -POSTHOOK: Input: default@dest1 +POSTHOOK: Input: default@dest2 #### A masked pattern was here #### NULL 2 -PREHOOK: query: EXPLAIN SELECT char_length(dest1.name) FROM dest1 +PREHOOK: query: EXPLAIN SELECT char_length(dest2.name) FROM dest2 PREHOOK: type: QUERY -POSTHOOK: query: EXPLAIN SELECT char_length(dest1.name) FROM dest1 +POSTHOOK: query: EXPLAIN SELECT char_length(dest2.name) FROM dest2 POSTHOOK: type: QUERY STAGE DEPENDENCIES: Stage-1 is a root stage @@ -253,19 +265,20 @@ STAGE PLANS: Map Reduce Map Operator Tree: TableScan - alias: dest1 - Statistics: Num rows: 1 Data size: 9 Basic stats: COMPLETE Column stats: NONE + alias: dest2 + Statistics: Num rows: 2 Data size: 90 Basic stats: COMPLETE Column stats: NONE Select Operator expressions: character_length(name) (type: int) outputColumnNames: _col0 - Statistics: Num rows: 1 Data size: 9 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 2 Data size: 90 Basic stats: COMPLETE Column stats: NONE File Output Operator compressed: false - Statistics: Num rows: 1 Data size: 9 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 2 Data size: 90 Basic stats: COMPLETE Column stats: NONE table: input format: org.apache.hadoop.mapred.SequenceFileInputFormat output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe + Execution mode: vectorized Stage: Stage-0 Fetch Operator @@ -273,13 +286,13 @@ STAGE PLANS: Processor Tree: ListSink -PREHOOK: query: SELECT char_length(dest1.name) FROM dest1 +PREHOOK: query: SELECT char_length(dest2.name) FROM dest2 PREHOOK: type: QUERY -PREHOOK: Input: default@dest1 +PREHOOK: Input: default@dest2 #### A masked pattern was here #### -POSTHOOK: query: SELECT char_length(dest1.name) FROM dest1 +POSTHOOK: query: SELECT char_length(dest2.name) FROM dest2 POSTHOOK: type: QUERY -POSTHOOK: Input: default@dest1 +POSTHOOK: Input: default@dest2 #### A masked pattern was here #### NULL 2 @@ -291,3 +304,11 @@ POSTHOOK: query: DROP TABLE dest1 POSTHOOK: type: DROPTABLE POSTHOOK: Input: default@dest1 POSTHOOK: Output: default@dest1 +PREHOOK: query: DROP TABLE dest2 +PREHOOK: type: DROPTABLE +PREHOOK: Input: default@dest2 +PREHOOK: Output: default@dest2 +POSTHOOK: query: DROP TABLE dest2 +POSTHOOK: type: DROPTABLE +POSTHOOK: Input: default@dest2 +POSTHOOK: Output: default@dest2 diff --git ql/src/test/results/clientpositive/vector_udf_octet_length.q.out ql/src/test/results/clientpositive/vector_udf_octet_length.q.out index 9519c7f..37a6786 100644 --- ql/src/test/results/clientpositive/vector_udf_octet_length.q.out +++ ql/src/test/results/clientpositive/vector_udf_octet_length.q.out @@ -180,9 +180,20 @@ POSTHOOK: query: INSERT INTO dest1 VALUES(NULL) POSTHOOK: type: QUERY POSTHOOK: Output: default@dest1 POSTHOOK: Lineage: dest1.name SIMPLE [(values__tmp__table__1)values__tmp__table__1.FieldSchema(name:tmp_values_col1, type:string, comment:), ] -PREHOOK: query: EXPLAIN SELECT octet_length(dest1.name) FROM dest1 +PREHOOK: query: CREATE TABLE dest2 STORED AS ORC AS SELECT * FROM dest1 +PREHOOK: type: CREATETABLE_AS_SELECT +PREHOOK: Input: default@dest1 +PREHOOK: Output: database:default +PREHOOK: Output: default@dest2 +POSTHOOK: query: CREATE TABLE dest2 STORED AS ORC AS SELECT * FROM dest1 +POSTHOOK: type: CREATETABLE_AS_SELECT +POSTHOOK: Input: default@dest1 +POSTHOOK: Output: database:default +POSTHOOK: Output: default@dest2 +POSTHOOK: Lineage: dest2.name SIMPLE [(dest1)dest1.FieldSchema(name:name, type:string, comment:null), ] +PREHOOK: query: EXPLAIN SELECT octet_length(dest2.name) FROM dest2 PREHOOK: type: QUERY -POSTHOOK: query: EXPLAIN SELECT octet_length(dest1.name) FROM dest1 +POSTHOOK: query: EXPLAIN SELECT octet_length(dest2.name) FROM dest2 POSTHOOK: type: QUERY STAGE DEPENDENCIES: Stage-1 is a root stage @@ -193,19 +204,20 @@ STAGE PLANS: Map Reduce Map Operator Tree: TableScan - alias: dest1 - Statistics: Num rows: 1 Data size: 9 Basic stats: COMPLETE Column stats: NONE + alias: dest2 + Statistics: Num rows: 2 Data size: 90 Basic stats: COMPLETE Column stats: NONE Select Operator expressions: octet_length(name) (type: int) outputColumnNames: _col0 - Statistics: Num rows: 1 Data size: 9 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 2 Data size: 90 Basic stats: COMPLETE Column stats: NONE File Output Operator compressed: false - Statistics: Num rows: 1 Data size: 9 Basic stats: COMPLETE Column stats: NONE + Statistics: Num rows: 2 Data size: 90 Basic stats: COMPLETE Column stats: NONE table: input format: org.apache.hadoop.mapred.SequenceFileInputFormat output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe + Execution mode: vectorized Stage: Stage-0 Fetch Operator @@ -213,13 +225,13 @@ STAGE PLANS: Processor Tree: ListSink -PREHOOK: query: SELECT octet_length(dest1.name) FROM dest1 +PREHOOK: query: SELECT octet_length(dest2.name) FROM dest2 PREHOOK: type: QUERY -PREHOOK: Input: default@dest1 +PREHOOK: Input: default@dest2 #### A masked pattern was here #### -POSTHOOK: query: SELECT octet_length(dest1.name) FROM dest1 +POSTHOOK: query: SELECT octet_length(dest2.name) FROM dest2 POSTHOOK: type: QUERY -POSTHOOK: Input: default@dest1 +POSTHOOK: Input: default@dest2 #### A masked pattern was here #### NULL 6 @@ -231,3 +243,11 @@ POSTHOOK: query: DROP TABLE dest1 POSTHOOK: type: DROPTABLE POSTHOOK: Input: default@dest1 POSTHOOK: Output: default@dest1 +PREHOOK: query: DROP TABLE dest2 +PREHOOK: type: DROPTABLE +PREHOOK: Input: default@dest2 +PREHOOK: Output: default@dest2 +POSTHOOK: query: DROP TABLE dest2 +POSTHOOK: type: DROPTABLE +POSTHOOK: Input: default@dest2 +POSTHOOK: Output: default@dest2