| --! qt:dataset:src1 |
| --! qt:dataset:src |
| set hive.mapred.mode=nonstrict; |
| set hive.optimize.semijoin.conversion=true; |
| -- SORT_QUERY_RESULTS |
| |
| CREATE TABLE dest_j1_n22(key STRING, cnt INT); |
| |
| set hive.auto.convert.join=true; |
| set hive.auto.convert.join.noconditionaltask=true; |
| set hive.auto.convert.join.noconditionaltask.size=10000; |
| |
| -- Since the inputs are small, it should be automatically converted to mapjoin |
| |
| EXPLAIN |
| INSERT OVERWRITE TABLE dest_j1_n22 |
| SELECT subq1.key, count(1) as cnt |
| FROM (select x.key, count(1) as cnt from src1 x group by x.key) subq1 JOIN |
| (select y.key, count(1) as cnt from src y group by y.key) subq2 ON (subq1.key = subq2.key) |
| group by subq1.key; |
| |
| INSERT OVERWRITE TABLE dest_j1_n22 |
| SELECT subq1.key, count(1) as cnt |
| FROM (select x.key, count(1) as cnt from src1 x group by x.key) subq1 JOIN |
| (select y.key, count(1) as cnt from src y group by y.key) subq2 ON (subq1.key = subq2.key) |
| group by subq1.key; |
| |
| select * from dest_j1_n22; |