FAQ
Author: namit
Date: Mon Oct 8 22:22:56 2012
New Revision: 1395796

URL: http://svn.apache.org/viewvc?rev=1395796&view=rev
Log:
HIVE-3550 Early skipping for limit operator at reduce stage
(Navis via namit)



Modified:
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/ExecReducer.java

Modified: hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/ExecReducer.java
URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/ExecReducer.java?rev=1395796&r1=1395795&r2=1395796&view=diff
==============================================================================
--- hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/ExecReducer.java (original)
+++ hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/ExecReducer.java Mon Oct 8 22:22:56 2012
@@ -169,7 +169,9 @@ public class ExecReducer extends MapRedu

public void reduce(Object key, Iterator values, OutputCollector output,
Reporter reporter) throws IOException {
-
+ if (reducer.getDone()) {
+ return;
+ }
if (oc == null) {
// propagete reporter and output collector to all operators
oc = output;

Search Discussions

Related Discussions

Discussion Navigation
viewthread | post
posts ‹ prev | 1 of 1 | next ›
Discussion Overview
groupcommits @
categorieshive, hadoop
postedOct 8, '12 at 10:23p
activeOct 8, '12 at 10:23p
posts1
users1
websitehive.apache.org

1 user in discussion

Namit: 1 post

People

Translate

site design / logo © 2021 Grokbase