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

[gunther]

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
+  }
 }