blob: 1dead85552bbbf52acda5d47d1c4021b4f4f1c11 [file] [log] [blame]
--! qt:dataset:src
set hive.explain.user=false;
set mapred.job.name='test_parallel';
set hive.exec.parallel=true;
set hive.input.format=org.apache.hadoop.hive.ql.io.HiveInputFormat;
set hive.stats.column.autogather=true;
-- SORT_QUERY_RESULTS
create table if not exists src_a_n0 like src;
create table if not exists src_b_n1 like src;
explain
from (select key, value from src group by key, value) s
insert overwrite table src_a_n0 select s.key, s.value group by s.key, s.value
insert overwrite table src_b_n1 select s.key, s.value group by s.key, s.value;
from (select key, value from src group by key, value) s
insert overwrite table src_a_n0 select s.key, s.value group by s.key, s.value
insert overwrite table src_b_n1 select s.key, s.value group by s.key, s.value;
select * from src_a_n0;
select * from src_b_n1;
set hive.input.format=org.apache.hadoop.hive.ql.io.CombineHiveInputFormat;
from (select key, value from src group by key, value) s
insert overwrite table src_a_n0 select s.key, s.value group by s.key, s.value
insert overwrite table src_b_n1 select s.key, s.value group by s.key, s.value;
select * from src_a_n0;
select * from src_b_n1;