diff --git build-common.xml build-common.xml index d642b51..afb1f3d 100644 --- build-common.xml +++ build-common.xml @@ -59,7 +59,7 @@ - + diff --git data/files/left_semi_join_t1.txt data/files/left_semi_join_t1.txt new file mode 100644 index 0000000..6ed281c --- /dev/null +++ data/files/left_semi_join_t1.txt @@ -0,0 +1,2 @@ +1 +1 diff --git data/files/left_semi_join_t2.txt data/files/left_semi_join_t2.txt new file mode 100644 index 0000000..179ef0e --- /dev/null +++ data/files/left_semi_join_t2.txt @@ -0,0 +1,20 @@ +1 +1 +1 +1 +1 +1 +1 +1 +1 +1 +1 +1 +1 +1 +1 +1 +1 +1 +1 +1 diff --git ql/src/test/queries/clientpositive/left_semi_join.q ql/src/test/queries/clientpositive/left_semi_join.q new file mode 100644 index 0000000..d3c8561 --- /dev/null +++ ql/src/test/queries/clientpositive/left_semi_join.q @@ -0,0 +1,20 @@ +CREATE TABLE T1(key INT); +LOAD DATA LOCAL INPATH '../data/files/left_semi_join_t1.txt' INTO TABLE T1; +CREATE TABLE T2(key INT); +LOAD DATA LOCAL INPATH '../data/files/left_semi_join_t2.txt' INTO TABLE T2; + +-- Run this query using TestMinimrCliDriver + +SELECT * FROM T1; +SELECT * FROM T2; + +set hive.auto.convert.join=false; +set mapred.reduce.tasks=2; + +set hive.join.emit.interval=100; + +SELECT T1.key FROM T1 LEFT SEMI JOIN (SELECT key FROM T2 SORT BY key) tmp ON (T1.key=tmp.key); + +set hive.join.emit.interval=1; + +SELECT T1.key FROM T1 LEFT SEMI JOIN (SELECT key FROM T2 SORT BY key) tmp ON (T1.key=tmp.key);