----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/25774/ -----------------------------------------------------------
Review request for hive and Xuefu Zhang. Bugs: HIVE-8043 https://issues.apache.org/jira/browse/HIVE-8043 Repository: hive-git Description ------- Support merging files for spark. For non-rc files, the merging task is simply a MapWork. For RC/Orc files, the merging task is a MergeFileWork. And SparkMergeFileRecordHandler is added to handle it. Diffs ----- ql/src/java/org/apache/hadoop/hive/ql/exec/spark/HiveMapFunction.java 5078a3a ql/src/java/org/apache/hadoop/hive/ql/exec/spark/HiveMapFunctionResultList.java c54bffe ql/src/java/org/apache/hadoop/hive/ql/exec/spark/SparkMapRecordHandler.java 2537789 ql/src/java/org/apache/hadoop/hive/ql/exec/spark/SparkMergeFileRecordHandler.java PRE-CREATION ql/src/java/org/apache/hadoop/hive/ql/exec/spark/SparkPlanGenerator.java 9b11fe4 ql/src/java/org/apache/hadoop/hive/ql/exec/spark/SparkRecordHandler.java 3eea26a ql/src/java/org/apache/hadoop/hive/ql/exec/spark/SparkReduceRecordHandler.java 94ebcdd ql/src/java/org/apache/hadoop/hive/ql/optimizer/GenMapRedUtils.java b0a9407 ql/src/test/queries/clientpositive/disable_merge_for_bucketing.q 471d296 ql/src/test/queries/clientpositive/merge1.q c7249af ql/src/test/queries/clientpositive/merge2.q bb86dc2 ql/src/test/results/clientpositive/spark/merge1.q.out 772984d ql/src/test/results/clientpositive/spark/merge2.q.out 8d8dcb8 Diff: https://reviews.apache.org/r/25774/diff/ Testing ------- Thanks, Rui Li