| PREHOOK: query: create table tmp_tmp_n0(key string, value string) stored as rcfile |
| PREHOOK: type: CREATETABLE |
| PREHOOK: Output: database:default |
| PREHOOK: Output: default@tmp_tmp_n0 |
| POSTHOOK: query: create table tmp_tmp_n0(key string, value string) stored as rcfile |
| POSTHOOK: type: CREATETABLE |
| POSTHOOK: Output: database:default |
| POSTHOOK: Output: default@tmp_tmp_n0 |
| PREHOOK: query: insert overwrite table tmp_tmp_n0 |
| SELECT TRANSFORM(key, value) USING |
| 'python newline.py' AS key, value FROM src limit 6 |
| PREHOOK: type: QUERY |
| PREHOOK: Input: default@src |
| PREHOOK: Output: default@tmp_tmp_n0 |
| POSTHOOK: query: insert overwrite table tmp_tmp_n0 |
| SELECT TRANSFORM(key, value) USING |
| 'python newline.py' AS key, value FROM src limit 6 |
| POSTHOOK: type: QUERY |
| POSTHOOK: Input: default@src |
| POSTHOOK: Output: default@tmp_tmp_n0 |
| POSTHOOK: Lineage: tmp_tmp_n0.key SCRIPT [(src)src.FieldSchema(name:key, type:string, comment:default), (src)src.FieldSchema(name:value, type:string, comment:default), ] |
| POSTHOOK: Lineage: tmp_tmp_n0.value SCRIPT [(src)src.FieldSchema(name:key, type:string, comment:default), (src)src.FieldSchema(name:value, type:string, comment:default), ] |
| PREHOOK: query: select * from tmp_tmp_n0 |
| PREHOOK: type: QUERY |
| PREHOOK: Input: default@tmp_tmp_n0 |
| PREHOOK: Output: hdfs://### HDFS PATH ### |
| POSTHOOK: query: select * from tmp_tmp_n0 |
| POSTHOOK: type: QUERY |
| POSTHOOK: Input: default@tmp_tmp_n0 |
| POSTHOOK: Output: hdfs://### HDFS PATH ### |
| 1 2 NULL |
| 1 2 NULL |
| 1 |
| 2 NULL |
| 1 |
| 2 NULL |
| 1 |
| 2 NULL |
| 1 |
| 2 NULL |
| PREHOOK: query: drop table tmp_tmp_n0 |
| PREHOOK: type: DROPTABLE |
| PREHOOK: Input: default@tmp_tmp_n0 |
| PREHOOK: Output: default@tmp_tmp_n0 |
| POSTHOOK: query: drop table tmp_tmp_n0 |
| POSTHOOK: type: DROPTABLE |
| POSTHOOK: Input: default@tmp_tmp_n0 |
| POSTHOOK: Output: default@tmp_tmp_n0 |
| PREHOOK: query: create table tmp_tmp_n0(key string, value string) stored as rcfile |
| PREHOOK: type: CREATETABLE |
| PREHOOK: Output: database:default |
| PREHOOK: Output: default@tmp_tmp_n0 |
| POSTHOOK: query: create table tmp_tmp_n0(key string, value string) stored as rcfile |
| POSTHOOK: type: CREATETABLE |
| POSTHOOK: Output: database:default |
| POSTHOOK: Output: default@tmp_tmp_n0 |
| PREHOOK: query: insert overwrite table tmp_tmp_n0 |
| SELECT TRANSFORM(key, value) USING |
| 'python escapednewline.py' AS key, value FROM src limit 5 |
| PREHOOK: type: QUERY |
| PREHOOK: Input: default@src |
| PREHOOK: Output: default@tmp_tmp_n0 |
| POSTHOOK: query: insert overwrite table tmp_tmp_n0 |
| SELECT TRANSFORM(key, value) USING |
| 'python escapednewline.py' AS key, value FROM src limit 5 |
| POSTHOOK: type: QUERY |
| POSTHOOK: Input: default@src |
| POSTHOOK: Output: default@tmp_tmp_n0 |
| POSTHOOK: Lineage: tmp_tmp_n0.key SCRIPT [(src)src.FieldSchema(name:key, type:string, comment:default), (src)src.FieldSchema(name:value, type:string, comment:default), ] |
| POSTHOOK: Lineage: tmp_tmp_n0.value SCRIPT [(src)src.FieldSchema(name:key, type:string, comment:default), (src)src.FieldSchema(name:value, type:string, comment:default), ] |
| PREHOOK: query: select * from tmp_tmp_n0 |
| PREHOOK: type: QUERY |
| PREHOOK: Input: default@tmp_tmp_n0 |
| PREHOOK: Output: hdfs://### HDFS PATH ### |
| POSTHOOK: query: select * from tmp_tmp_n0 |
| POSTHOOK: type: QUERY |
| POSTHOOK: Input: default@tmp_tmp_n0 |
| POSTHOOK: Output: hdfs://### HDFS PATH ### |
| 1\n2 NULL |
| 1\n2 NULL |
| 1\n2 NULL |
| 1\n2 NULL |
| 1\n2 NULL |
| PREHOOK: query: SELECT TRANSFORM(key, value) USING |
| 'cat' AS (key, value) FROM tmp_tmp_n0 |
| PREHOOK: type: QUERY |
| PREHOOK: Input: default@tmp_tmp_n0 |
| PREHOOK: Output: hdfs://### HDFS PATH ### |
| POSTHOOK: query: SELECT TRANSFORM(key, value) USING |
| 'cat' AS (key, value) FROM tmp_tmp_n0 |
| POSTHOOK: type: QUERY |
| POSTHOOK: Input: default@tmp_tmp_n0 |
| POSTHOOK: Output: hdfs://### HDFS PATH ### |
| 1\n2 NULL |
| 1\n2 NULL |
| 1\n2 NULL |
| 1\n2 NULL |
| 1\n2 NULL |
| PREHOOK: query: insert overwrite table tmp_tmp_n0 |
| SELECT TRANSFORM(key, value) USING |
| 'python escapedcarriagereturn.py' AS key, value FROM src limit 5 |
| PREHOOK: type: QUERY |
| PREHOOK: Input: default@src |
| PREHOOK: Output: default@tmp_tmp_n0 |
| POSTHOOK: query: insert overwrite table tmp_tmp_n0 |
| SELECT TRANSFORM(key, value) USING |
| 'python escapedcarriagereturn.py' AS key, value FROM src limit 5 |
| POSTHOOK: type: QUERY |
| POSTHOOK: Input: default@src |
| POSTHOOK: Output: default@tmp_tmp_n0 |
| POSTHOOK: Lineage: tmp_tmp_n0.key SCRIPT [(src)src.FieldSchema(name:key, type:string, comment:default), (src)src.FieldSchema(name:value, type:string, comment:default), ] |
| POSTHOOK: Lineage: tmp_tmp_n0.value SCRIPT [(src)src.FieldSchema(name:key, type:string, comment:default), (src)src.FieldSchema(name:value, type:string, comment:default), ] |
| PREHOOK: query: select * from tmp_tmp_n0 |
| PREHOOK: type: QUERY |
| PREHOOK: Input: default@tmp_tmp_n0 |
| PREHOOK: Output: hdfs://### HDFS PATH ### |
| POSTHOOK: query: select * from tmp_tmp_n0 |
| POSTHOOK: type: QUERY |
| POSTHOOK: Input: default@tmp_tmp_n0 |
| POSTHOOK: Output: hdfs://### HDFS PATH ### |
| 1\r2 NULL |
| 1\r2 NULL |
| 1\r2 NULL |
| 1\r2 NULL |
| 1\r2 NULL |
| PREHOOK: query: SELECT TRANSFORM(key, value) USING |
| 'cat' AS (key, value) FROM tmp_tmp_n0 |
| PREHOOK: type: QUERY |
| PREHOOK: Input: default@tmp_tmp_n0 |
| PREHOOK: Output: hdfs://### HDFS PATH ### |
| POSTHOOK: query: SELECT TRANSFORM(key, value) USING |
| 'cat' AS (key, value) FROM tmp_tmp_n0 |
| POSTHOOK: type: QUERY |
| POSTHOOK: Input: default@tmp_tmp_n0 |
| POSTHOOK: Output: hdfs://### HDFS PATH ### |
| 1\r2 NULL |
| 1\r2 NULL |
| 1\r2 NULL |
| 1\r2 NULL |
| 1\r2 NULL |
| PREHOOK: query: insert overwrite table tmp_tmp_n0 |
| SELECT TRANSFORM(key, value) USING |
| 'python escapedtab.py' AS key, value FROM src limit 5 |
| PREHOOK: type: QUERY |
| PREHOOK: Input: default@src |
| PREHOOK: Output: default@tmp_tmp_n0 |
| POSTHOOK: query: insert overwrite table tmp_tmp_n0 |
| SELECT TRANSFORM(key, value) USING |
| 'python escapedtab.py' AS key, value FROM src limit 5 |
| POSTHOOK: type: QUERY |
| POSTHOOK: Input: default@src |
| POSTHOOK: Output: default@tmp_tmp_n0 |
| POSTHOOK: Lineage: tmp_tmp_n0.key SCRIPT [(src)src.FieldSchema(name:key, type:string, comment:default), (src)src.FieldSchema(name:value, type:string, comment:default), ] |
| POSTHOOK: Lineage: tmp_tmp_n0.value SCRIPT [(src)src.FieldSchema(name:key, type:string, comment:default), (src)src.FieldSchema(name:value, type:string, comment:default), ] |
| PREHOOK: query: select * from tmp_tmp_n0 |
| PREHOOK: type: QUERY |
| PREHOOK: Input: default@tmp_tmp_n0 |
| PREHOOK: Output: hdfs://### HDFS PATH ### |
| POSTHOOK: query: select * from tmp_tmp_n0 |
| POSTHOOK: type: QUERY |
| POSTHOOK: Input: default@tmp_tmp_n0 |
| POSTHOOK: Output: hdfs://### HDFS PATH ### |
| 1\t2 NULL |
| 1\t2 NULL |
| 1\t2 NULL |
| 1\t2 NULL |
| 1\t2 NULL |
| PREHOOK: query: SELECT TRANSFORM(key, value) USING |
| 'cat' AS (key, value) FROM tmp_tmp_n0 |
| PREHOOK: type: QUERY |
| PREHOOK: Input: default@tmp_tmp_n0 |
| PREHOOK: Output: hdfs://### HDFS PATH ### |
| POSTHOOK: query: SELECT TRANSFORM(key, value) USING |
| 'cat' AS (key, value) FROM tmp_tmp_n0 |
| POSTHOOK: type: QUERY |
| POSTHOOK: Input: default@tmp_tmp_n0 |
| POSTHOOK: Output: hdfs://### HDFS PATH ### |
| 1\t2 NULL |
| 1\t2 NULL |
| 1\t2 NULL |
| 1\t2 NULL |
| 1\t2 NULL |
| PREHOOK: query: insert overwrite table tmp_tmp_n0 |
| SELECT TRANSFORM(key, value) USING |
| 'python doubleescapedtab.py' AS key, value FROM src limit 5 |
| PREHOOK: type: QUERY |
| PREHOOK: Input: default@src |
| PREHOOK: Output: default@tmp_tmp_n0 |
| POSTHOOK: query: insert overwrite table tmp_tmp_n0 |
| SELECT TRANSFORM(key, value) USING |
| 'python doubleescapedtab.py' AS key, value FROM src limit 5 |
| POSTHOOK: type: QUERY |
| POSTHOOK: Input: default@src |
| POSTHOOK: Output: default@tmp_tmp_n0 |
| POSTHOOK: Lineage: tmp_tmp_n0.key SCRIPT [(src)src.FieldSchema(name:key, type:string, comment:default), (src)src.FieldSchema(name:value, type:string, comment:default), ] |
| POSTHOOK: Lineage: tmp_tmp_n0.value SCRIPT [(src)src.FieldSchema(name:key, type:string, comment:default), (src)src.FieldSchema(name:value, type:string, comment:default), ] |
| PREHOOK: query: select * from tmp_tmp_n0 |
| PREHOOK: type: QUERY |
| PREHOOK: Input: default@tmp_tmp_n0 |
| PREHOOK: Output: hdfs://### HDFS PATH ### |
| POSTHOOK: query: select * from tmp_tmp_n0 |
| POSTHOOK: type: QUERY |
| POSTHOOK: Input: default@tmp_tmp_n0 |
| POSTHOOK: Output: hdfs://### HDFS PATH ### |
| 1\ 2 NULL |
| 1\ 2 NULL |
| 1\ 2 NULL |
| 1\\t2 NULL |
| 1\\t2 NULL |
| PREHOOK: query: SELECT TRANSFORM(key, value) USING |
| 'cat' AS (key, value) FROM tmp_tmp_n0 |
| PREHOOK: type: QUERY |
| PREHOOK: Input: default@tmp_tmp_n0 |
| PREHOOK: Output: hdfs://### HDFS PATH ### |
| POSTHOOK: query: SELECT TRANSFORM(key, value) USING |
| 'cat' AS (key, value) FROM tmp_tmp_n0 |
| POSTHOOK: type: QUERY |
| POSTHOOK: Input: default@tmp_tmp_n0 |
| POSTHOOK: Output: hdfs://### HDFS PATH ### |
| 1\ 2 NULL |
| 1\ 2 NULL |
| 1\ 2 NULL |
| 1\\t2 NULL |
| 1\\t2 NULL |
| PREHOOK: query: SELECT key FROM (SELECT TRANSFORM ('a\tb', 'c') USING 'cat' AS (key, value) FROM src limit 1)a ORDER BY key ASC |
| PREHOOK: type: QUERY |
| PREHOOK: Input: default@src |
| PREHOOK: Output: hdfs://### HDFS PATH ### |
| POSTHOOK: query: SELECT key FROM (SELECT TRANSFORM ('a\tb', 'c') USING 'cat' AS (key, value) FROM src limit 1)a ORDER BY key ASC |
| POSTHOOK: type: QUERY |
| POSTHOOK: Input: default@src |
| POSTHOOK: Output: hdfs://### HDFS PATH ### |
| a b |
| PREHOOK: query: SELECT value FROM (SELECT TRANSFORM ('a\tb', 'c') USING 'cat' AS (key, value) FROM src limit 1)a ORDER BY value ASC |
| PREHOOK: type: QUERY |
| PREHOOK: Input: default@src |
| PREHOOK: Output: hdfs://### HDFS PATH ### |
| POSTHOOK: query: SELECT value FROM (SELECT TRANSFORM ('a\tb', 'c') USING 'cat' AS (key, value) FROM src limit 1)a ORDER BY value ASC |
| POSTHOOK: type: QUERY |
| POSTHOOK: Input: default@src |
| POSTHOOK: Output: hdfs://### HDFS PATH ### |
| c |