helix-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kisho...@apache.org
Subject [52/52] [abbrv] git commit: Adding new files
Date Wed, 20 Nov 2013 21:13:07 GMT
Adding new files


Project: http://git-wip-us.apache.org/repos/asf/incubator-helix/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-helix/commit/1ec06f55
Tree: http://git-wip-us.apache.org/repos/asf/incubator-helix/tree/1ec06f55
Diff: http://git-wip-us.apache.org/repos/asf/incubator-helix/diff/1ec06f55

Branch: refs/heads/helix-yarn
Commit: 1ec06f55fa9b78d47f4d1437244a82d362299942
Parents: 6dece84
Author: Kishore Gopalakrishna <g.kishore@gmail.com>
Authored: Wed Nov 20 13:11:37 2013 -0800
Committer: Kishore Gopalakrishna <g.kishore@gmail.com>
Committed: Wed Nov 20 13:11:37 2013 -0800

----------------------------------------------------------------------
 .../autoscale/impl/yarn/NMCallbackHandler.java  | 50 ++++++++++++++++++++
 .../autoscale/impl/yarn/RMCallbackHandler.java  | 48 +++++++++++++++++++
 2 files changed, 98 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-helix/blob/1ec06f55/recipes/auto-scale/src/main/java/org/apache/helix/autoscale/impl/yarn/NMCallbackHandler.java
----------------------------------------------------------------------
diff --git a/recipes/auto-scale/src/main/java/org/apache/helix/autoscale/impl/yarn/NMCallbackHandler.java
b/recipes/auto-scale/src/main/java/org/apache/helix/autoscale/impl/yarn/NMCallbackHandler.java
new file mode 100644
index 0000000..1c6421c
--- /dev/null
+++ b/recipes/auto-scale/src/main/java/org/apache/helix/autoscale/impl/yarn/NMCallbackHandler.java
@@ -0,0 +1,50 @@
+package org.apache.helix.autoscale.impl.yarn;
+
+import java.nio.ByteBuffer;
+import java.util.Map;
+
+import org.apache.hadoop.yarn.api.records.ContainerId;
+import org.apache.hadoop.yarn.api.records.ContainerStatus;
+import org.apache.hadoop.yarn.client.api.async.NMClientAsync;
+
+public class NMCallbackHandler implements NMClientAsync.CallbackHandler {
+
+	@Override
+	public void onContainerStarted(ContainerId containerId,
+			Map<String, ByteBuffer> allServiceResponse) {
+		// TODO Auto-generated method stub
+		
+	}
+
+	@Override
+	public void onContainerStatusReceived(ContainerId containerId,
+			ContainerStatus containerStatus) {
+		// TODO Auto-generated method stub
+		
+	}
+
+	@Override
+	public void onContainerStopped(ContainerId containerId) {
+		// TODO Auto-generated method stub
+		
+	}
+
+	@Override
+	public void onStartContainerError(ContainerId containerId, Throwable t) {
+		// TODO Auto-generated method stub
+		
+	}
+
+	@Override
+	public void onGetContainerStatusError(ContainerId containerId, Throwable t) {
+		// TODO Auto-generated method stub
+		
+	}
+
+	@Override
+	public void onStopContainerError(ContainerId containerId, Throwable t) {
+		// TODO Auto-generated method stub
+		
+	}
+
+}

http://git-wip-us.apache.org/repos/asf/incubator-helix/blob/1ec06f55/recipes/auto-scale/src/main/java/org/apache/helix/autoscale/impl/yarn/RMCallbackHandler.java
----------------------------------------------------------------------
diff --git a/recipes/auto-scale/src/main/java/org/apache/helix/autoscale/impl/yarn/RMCallbackHandler.java
b/recipes/auto-scale/src/main/java/org/apache/helix/autoscale/impl/yarn/RMCallbackHandler.java
new file mode 100644
index 0000000..187a1f2
--- /dev/null
+++ b/recipes/auto-scale/src/main/java/org/apache/helix/autoscale/impl/yarn/RMCallbackHandler.java
@@ -0,0 +1,48 @@
+package org.apache.helix.autoscale.impl.yarn;
+
+import java.util.List;
+
+import org.apache.hadoop.yarn.api.records.Container;
+import org.apache.hadoop.yarn.api.records.ContainerStatus;
+import org.apache.hadoop.yarn.api.records.NodeReport;
+import org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler;
+
+public class RMCallbackHandler implements CallbackHandler {
+
+	@Override
+	public void onContainersCompleted(List<ContainerStatus> statuses) {
+		// TODO Auto-generated method stub
+
+	}
+
+	@Override
+	public void onContainersAllocated(List<Container> containers) {
+		// TODO Auto-generated method stub
+
+	}
+
+	@Override
+	public void onShutdownRequest() {
+		// TODO Auto-generated method stub
+
+	}
+
+	@Override
+	public void onNodesUpdated(List<NodeReport> updatedNodes) {
+		// TODO Auto-generated method stub
+
+	}
+
+	@Override
+	public float getProgress() {
+		// TODO Auto-generated method stub
+		return 0;
+	}
+
+	@Override
+	public void onError(Throwable e) {
+		// TODO Auto-generated method stub
+
+	}
+
+}


Mime
View raw message