tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ss...@apache.org
Subject git commit: TEZ-1447 addendum. Fix name of registration API. (sseth)
Date Mon, 08 Sep 2014 03:28:58 GMT
Repository: tez
Updated Branches:
  refs/heads/master 44e6a77cc -> ee0c96379


TEZ-1447 addendum. Fix name of registration API. (sseth)


Project: http://git-wip-us.apache.org/repos/asf/tez/repo
Commit: http://git-wip-us.apache.org/repos/asf/tez/commit/ee0c9637
Tree: http://git-wip-us.apache.org/repos/asf/tez/tree/ee0c9637
Diff: http://git-wip-us.apache.org/repos/asf/tez/diff/ee0c9637

Branch: refs/heads/master
Commit: ee0c96379128947bb44ca6f86f016542045e7254
Parents: 44e6a77
Author: Siddharth Seth <sseth@apache.org>
Authored: Sun Sep 7 20:28:12 2014 -0700
Committer: Siddharth Seth <sseth@apache.org>
Committed: Sun Sep 7 20:28:12 2014 -0700

----------------------------------------------------------------------
 .../src/main/java/org/apache/tez/runtime/api/InputInitializer.java | 2 +-
 .../java/org/apache/tez/runtime/api/InputInitializerContext.java   | 2 +-
 .../tez/dag/app/dag/impl/TezRootInputInitializerContextImpl.java   | 2 +-
 .../test/java/org/apache/tez/dag/app/dag/impl/TestVertexImpl.java  | 2 +-
 .../apache/tez/mapreduce/common/TestMRInputSplitDistributor.java   | 2 +-
 5 files changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/tez/blob/ee0c9637/tez-api/src/main/java/org/apache/tez/runtime/api/InputInitializer.java
----------------------------------------------------------------------
diff --git a/tez-api/src/main/java/org/apache/tez/runtime/api/InputInitializer.java b/tez-api/src/main/java/org/apache/tez/runtime/api/InputInitializer.java
index 3ab5cdb..00896de 100644
--- a/tez-api/src/main/java/org/apache/tez/runtime/api/InputInitializer.java
+++ b/tez-api/src/main/java/org/apache/tez/runtime/api/InputInitializer.java
@@ -91,7 +91,7 @@ public abstract class InputInitializer {
    * Receive notifications on vertex state changes.
    * <p/>
    * State changes will be received based on the registration via {@link
-   * org.apache.tez.runtime.api.InputInitializerContext#registerForVertexStatusUpdates(String,
+   * org.apache.tez.runtime.api.InputInitializerContext#registerForVertexStateUpdates(String,
    * java.util.Set)}. Notifications will be received for all registered state changes, and
not just
    * for the latest state update. They will be in order in which the state change occurred.
    *

http://git-wip-us.apache.org/repos/asf/tez/blob/ee0c9637/tez-api/src/main/java/org/apache/tez/runtime/api/InputInitializerContext.java
----------------------------------------------------------------------
diff --git a/tez-api/src/main/java/org/apache/tez/runtime/api/InputInitializerContext.java
b/tez-api/src/main/java/org/apache/tez/runtime/api/InputInitializerContext.java
index fe82b54..6a123cf 100644
--- a/tez-api/src/main/java/org/apache/tez/runtime/api/InputInitializerContext.java
+++ b/tez-api/src/main/java/org/apache/tez/runtime/api/InputInitializerContext.java
@@ -115,6 +115,6 @@ public interface InputInitializerContext {
    * @param vertexName the vertex name for which notifications are required.
    * @param stateSet   the set of states for which notifications are required. null implies
all
    */
-  void registerForVertexStatusUpdates(String vertexName, @Nullable Set<VertexState>
stateSet);
+  void registerForVertexStateUpdates(String vertexName, @Nullable Set<VertexState>
stateSet);
 
 }

http://git-wip-us.apache.org/repos/asf/tez/blob/ee0c9637/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/TezRootInputInitializerContextImpl.java
----------------------------------------------------------------------
diff --git a/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/TezRootInputInitializerContextImpl.java
b/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/TezRootInputInitializerContextImpl.java
index 846d208..d4ef4d5 100644
--- a/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/TezRootInputInitializerContextImpl.java
+++ b/tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/TezRootInputInitializerContextImpl.java
@@ -115,7 +115,7 @@ public class TezRootInputInitializerContextImpl implements
   }
 
   @Override
-  public void registerForVertexStatusUpdates(String vertexName, Set<VertexState> stateSet)
{
+  public void registerForVertexStateUpdates(String vertexName, Set<VertexState> stateSet)
{
     manager.registerForVertexUpdates(vertexName, input.getName(), stateSet);
   }
 

http://git-wip-us.apache.org/repos/asf/tez/blob/ee0c9637/tez-dag/src/test/java/org/apache/tez/dag/app/dag/impl/TestVertexImpl.java
----------------------------------------------------------------------
diff --git a/tez-dag/src/test/java/org/apache/tez/dag/app/dag/impl/TestVertexImpl.java b/tez-dag/src/test/java/org/apache/tez/dag/app/dag/impl/TestVertexImpl.java
index 31aaf6f..d894928 100644
--- a/tez-dag/src/test/java/org/apache/tez/dag/app/dag/impl/TestVertexImpl.java
+++ b/tez-dag/src/test/java/org/apache/tez/dag/app/dag/impl/TestVertexImpl.java
@@ -3662,7 +3662,7 @@ public class TestVertexImpl {
 
     @Override
     public List<Event> initialize() throws Exception {
-      context.registerForVertexStatusUpdates("vertex1", null);
+      context.registerForVertexStateUpdates("vertex1", null);
       initStarted.set(true);
       lock.lock();
       try {

http://git-wip-us.apache.org/repos/asf/tez/blob/ee0c9637/tez-mapreduce/src/test/java/org/apache/tez/mapreduce/common/TestMRInputSplitDistributor.java
----------------------------------------------------------------------
diff --git a/tez-mapreduce/src/test/java/org/apache/tez/mapreduce/common/TestMRInputSplitDistributor.java
b/tez-mapreduce/src/test/java/org/apache/tez/mapreduce/common/TestMRInputSplitDistributor.java
index 55f9b11..7f31741 100644
--- a/tez-mapreduce/src/test/java/org/apache/tez/mapreduce/common/TestMRInputSplitDistributor.java
+++ b/tez-mapreduce/src/test/java/org/apache/tez/mapreduce/common/TestMRInputSplitDistributor.java
@@ -212,7 +212,7 @@ public class TestMRInputSplitDistributor {
     }
 
     @Override
-    public void registerForVertexStatusUpdates(String vertexName, Set<VertexState>
stateSet) {
+    public void registerForVertexStateUpdates(String vertexName, Set<VertexState> stateSet)
{
       throw new UnsupportedOperationException("getVertexNumTasks not implemented in this
mock");
     }
 


Mime
View raw message