| --! qt:dataset:src | |
| set hive.mapred.mode=nonstrict; | |
| dfs -put ../../data/scripts/newline.py /newline.py; | |
| add file hdfs:///newline.py; | |
| set hive.transform.escape.input=true; | |
| create table tmp_tmp(key string, value string) stored as rcfile; | |
| insert overwrite table tmp_tmp | |
| SELECT TRANSFORM(key, value) USING | |
| 'python newline.py' AS key, value FROM src limit 6; | |
| select * from tmp_tmp ORDER BY key ASC, value ASC; | |
| dfs -rmr /newline.py; | |
| drop table tmp_tmp; |