Repository: apex-core Updated Branches: refs/heads/master 3d0cefce5 -> 0bdf771f8
APEXCORE-543 ContainerInfo will contain Map of operators, with Key representing Id and Value representing name. Project: http://git-wip-us.apache.org/repos/asf/apex-core/repo Commit: http://git-wip-us.apache.org/repos/asf/apex-core/commit/0bdf771f Tree: http://git-wip-us.apache.org/repos/asf/apex-core/tree/0bdf771f Diff: http://git-wip-us.apache.org/repos/asf/apex-core/diff/0bdf771f Branch: refs/heads/master Commit: 0bdf771f8c7d94df523ec381c4a92f5517e83dc9 Parents: 3d0cefc Author: Sandesh Hegde <[email protected]> Authored: Fri Sep 30 16:09:15 2016 -0700 Committer: Sandesh Hegde <[email protected]> Committed: Mon Oct 3 15:39:48 2016 -0700 ---------------------------------------------------------------------- .../java/com/datatorrent/stram/StreamingContainerAgent.java | 7 +++++++ .../main/java/com/datatorrent/stram/webapp/ContainerInfo.java | 3 +++ 2 files changed, 10 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/apex-core/blob/0bdf771f/engine/src/main/java/com/datatorrent/stram/StreamingContainerAgent.java ---------------------------------------------------------------------- diff --git a/engine/src/main/java/com/datatorrent/stram/StreamingContainerAgent.java b/engine/src/main/java/com/datatorrent/stram/StreamingContainerAgent.java index 13a1000..2ea37f4 100644 --- a/engine/src/main/java/com/datatorrent/stram/StreamingContainerAgent.java +++ b/engine/src/main/java/com/datatorrent/stram/StreamingContainerAgent.java @@ -26,6 +26,7 @@ import java.util.LinkedHashMap; import java.util.List; import java.util.Map; import java.util.Set; +import java.util.TreeMap; import java.util.concurrent.ConcurrentLinkedQueue; import org.slf4j.Logger; @@ -450,6 +451,12 @@ public class StreamingContainerAgent ci.state = container.getState().name(); ci.jvmName = this.jvmName; ci.numOperators = container.getOperators().size(); + ci.operators = new TreeMap<>(); + + for (PTOperator ptOperator : container.getOperators()) { + ci.operators.put(ptOperator.getId(), ptOperator.getName()); + } + ci.memoryMBAllocated = container.getAllocatedMemoryMB(); ci.lastHeartbeat = lastHeartbeatMillis; ci.memoryMBFree = this.memoryMBFree; http://git-wip-us.apache.org/repos/asf/apex-core/blob/0bdf771f/engine/src/main/java/com/datatorrent/stram/webapp/ContainerInfo.java ---------------------------------------------------------------------- diff --git a/engine/src/main/java/com/datatorrent/stram/webapp/ContainerInfo.java b/engine/src/main/java/com/datatorrent/stram/webapp/ContainerInfo.java index 4696fb6..ea124eb 100644 --- a/engine/src/main/java/com/datatorrent/stram/webapp/ContainerInfo.java +++ b/engine/src/main/java/com/datatorrent/stram/webapp/ContainerInfo.java @@ -18,6 +18,8 @@ */ package com.datatorrent.stram.webapp; +import java.util.Map; + import javax.xml.bind.annotation.XmlAccessType; import javax.xml.bind.annotation.XmlAccessorType; import javax.xml.bind.annotation.XmlRootElement; @@ -43,6 +45,7 @@ public class ContainerInfo public long lastHeartbeat; @RecordField(type = "stats") public int numOperators; + public Map<Integer, String> operators; @RecordField(type = "meta") public int memoryMBAllocated; @RecordField(type = "stats")
