You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@helix.apache.org by ki...@apache.org on 2013/11/20 22:13:07 UTC
[52/52] [abbrv] git commit: Adding new files
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....@gmail.com>
Authored: Wed Nov 20 13:11:37 2013 -0800
Committer: Kishore Gopalakrishna <g....@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
+
+ }
+
+}