----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/27627/ -----------------------------------------------------------
(Updated Nov. 9, 2014, 10:39 p.m.) Review request for hive. Changes ------- Adopting Xuefu's pseudo code. Now for each BaseWork with MJ operator, use a SparkWork for its parent BaseWorks that contain HashTableSinkOperator. I manually tested this patch with several qfiles containing map-join queries, and results look correct. Bugs: HIVE-8622 https://issues.apache.org/jira/browse/HIVE-8622 Repository: hive-git Description ------- This is a sub-task of map-join for spark https://issues.apache.org/jira/browse/HIVE-7613 This can use the baseline patch for map-join https://issues.apache.org/jira/browse/HIVE-8616 Diffs (updated) ----- ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/SparkMapJoinResolver.java PRE-CREATION ql/src/java/org/apache/hadoop/hive/ql/plan/SparkWork.java 46d02bf Diff: https://reviews.apache.org/r/27627/diff/ Testing ------- Thanks, Chao Sun