You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@hive.apache.org by gu...@apache.org on 2014/02/24 21:17:05 UTC

svn commit: r1571424 - /hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/tools/TezMergedLogicalInput.java

Author: gunther
Date: Mon Feb 24 20:17:05 2014
New Revision: 1571424

URL: http://svn.apache.org/r1571424
Log:
HIVE-6493: Tez 0.3.0 API change (Gunther Hagleitner)

Modified:
    hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/tools/TezMergedLogicalInput.java

Modified: hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/tools/TezMergedLogicalInput.java
URL: http://svn.apache.org/viewvc/hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/tools/TezMergedLogicalInput.java?rev=1571424&r1=1571423&r2=1571424&view=diff
==============================================================================
--- hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/tools/TezMergedLogicalInput.java (original)
+++ hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/tools/TezMergedLogicalInput.java Mon Feb 24 20:17:05 2014
@@ -21,6 +21,7 @@ import java.util.List;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
+import org.apache.tez.runtime.api.Input;
 import org.apache.tez.runtime.api.LogicalInput;
 import org.apache.tez.runtime.api.MergedLogicalInput;
 import org.apache.tez.runtime.api.Reader;
@@ -35,4 +36,9 @@ public class TezMergedLogicalInput exten
   public Reader getReader() throws Exception {
     return new InputMerger(getInputs());
   }
+
+  @Override
+  public void setConstituentInputIsReady(Input input) {
+    // ignore notification
+  }
 }