You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tez.apache.org by ss...@apache.org on 2014/09/08 05:28:58 UTC
git commit: TEZ-1447 addendum. Fix name of registration API. (sseth)
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 <ss...@apache.org>
Authored: Sun Sep 7 20:28:12 2014 -0700
Committer: Siddharth Seth <ss...@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");
}