blob: fb425b7044463c759b8d55d71bbd1405b145bc14 [file] [log] [blame]
--! qt:dataset:src
CREATE TABLE dest1_n138(key INT, value STRING) STORED AS TEXTFILE;
ADD FILE ../../data/scripts/input20_script.py;
EXPLAIN
FROM (
FROM src
MAP src.key, src.key
USING 'cat'
DISTRIBUTE BY key, value
) tmap
INSERT OVERWRITE TABLE dest1_n138
REDUCE tmap.key, tmap.value
USING 'python input20_script.py'
AS key, value;
FROM (
FROM src
MAP src.key, src.key
USING 'cat'
DISTRIBUTE BY key, value
) tmap
INSERT OVERWRITE TABLE dest1_n138
REDUCE tmap.key, tmap.value
USING 'python input20_script.py'
AS key, value;
SELECT * FROM dest1_n138 ORDER BY key, value;