| --! qt:dataset:src1 |
| --! qt:dataset:src |
| set hive.mapred.mode=nonstrict; |
| -- SORT_QUERY_RESULTS |
| |
| CREATE TABLE dest_j1_n1(key STRING, value STRING, val2 STRING) STORED AS TEXTFILE; |
| |
| 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 EXTENDED |
| INSERT OVERWRITE TABLE dest_j1_n1 |
| SELECT x.key, x.value, subq1.value |
| FROM |
| ( SELECT x.key as key, x.value as value from src x where x.key < 20 |
| UNION ALL |
| SELECT x1.key as key, x1.value as value from src x1 where x1.key > 100 |
| ) subq1 |
| JOIN src1 x ON (x.key = subq1.key); |
| |
| INSERT OVERWRITE TABLE dest_j1_n1 |
| SELECT x.key, x.value, subq1.value |
| FROM |
| ( SELECT x.key as key, x.value as value from src x where x.key < 20 |
| UNION ALL |
| SELECT x1.key as key, x1.value as value from src x1 where x1.key > 100 |
| ) subq1 |
| JOIN src1 x ON (x.key = subq1.key); |
| |
| select * from dest_j1_n1; |
| |
| |
| |
