blob: f886a3e410a60d5725872da00711d6f678e2e302 [file] [log] [blame]
--! qt:dataset:src
set hive.mapred.mode=nonstrict;
add file ../../data/scripts/newline.py;
set hive.transform.escape.input=true;
-- SORT_QUERY_RESULTS
create table tmp_tmp_n0(key string, value string) stored as rcfile;
insert overwrite table tmp_tmp_n0
SELECT TRANSFORM(key, value) USING
'python newline.py' AS key, value FROM src limit 6;
select * from tmp_tmp_n0;
drop table tmp_tmp_n0;
add file ../../data/scripts/escapednewline.py;
add file ../../data/scripts/escapedtab.py;
add file ../../data/scripts/doubleescapedtab.py;
add file ../../data/scripts/escapedcarriagereturn.py;
create table tmp_tmp_n0(key string, value string) stored as rcfile;
insert overwrite table tmp_tmp_n0
SELECT TRANSFORM(key, value) USING
'python escapednewline.py' AS key, value FROM src limit 5;
select * from tmp_tmp_n0;
SELECT TRANSFORM(key, value) USING
'cat' AS (key, value) FROM tmp_tmp_n0;
insert overwrite table tmp_tmp_n0
SELECT TRANSFORM(key, value) USING
'python escapedcarriagereturn.py' AS key, value FROM src limit 5;
select * from tmp_tmp_n0;
SELECT TRANSFORM(key, value) USING
'cat' AS (key, value) FROM tmp_tmp_n0;
insert overwrite table tmp_tmp_n0
SELECT TRANSFORM(key, value) USING
'python escapedtab.py' AS key, value FROM src limit 5;
select * from tmp_tmp_n0;
SELECT TRANSFORM(key, value) USING
'cat' AS (key, value) FROM tmp_tmp_n0;
insert overwrite table tmp_tmp_n0
SELECT TRANSFORM(key, value) USING
'python doubleescapedtab.py' AS key, value FROM src limit 5;
select * from tmp_tmp_n0;
SELECT TRANSFORM(key, value) USING
'cat' AS (key, value) FROM tmp_tmp_n0;
SELECT key FROM (SELECT TRANSFORM ('a\tb', 'c') USING 'cat' AS (key, value) FROM src limit 1)a ORDER BY key ASC;
SELECT value FROM (SELECT TRANSFORM ('a\tb', 'c') USING 'cat' AS (key, value) FROM src limit 1)a ORDER BY value ASC;