| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/event/ |
| H A D | NodeAddedSchedulerEvent.java | 29 private final List<NMContainerStatus> containerReports; field in NodeAddedSchedulerEvent
34 this.containerReports = null; in NodeAddedSchedulerEvent()
38 List<NMContainerStatus> containerReports) { in NodeAddedSchedulerEvent() argument
41 this.containerReports = containerReports; in NodeAddedSchedulerEvent()
49 return containerReports; in getContainerReports()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/rmnode/ |
| H A D | RMNodeStartedEvent.java | 33 List<NMContainerStatus> containerReports, in RMNodeStartedEvent() argument
36 this.containerStatuses = containerReports; in RMNodeStartedEvent()
|
| H A D | RMNodeReconnectEvent.java | 33 List<ApplicationId> runningApps, List<NMContainerStatus> containerReports) { in RMNodeReconnectEvent() argument
37 containerStatuses = containerReports; in RMNodeReconnectEvent()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/api/protocolrecords/impl/pb/ |
| H A D | RegisterNodeManagerRequestPBImpl.java | 257 List<NMContainerStatus> containerReports) { in setContainerStatuses() argument
258 if (containerReports == null) { in setContainerStatuses()
262 this.containerStatuses.addAll(containerReports); in setContainerStatuses()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/test/java/org/apache/hadoop/yarn/client/api/impl/ |
| H A D | TestAHSClient.java | 369 List<ContainerReport> containerReports = new ArrayList<ContainerReport>(); in createAppReports() local
376 containerReports.add(container); in createAppReports()
384 containerReports.add(container1); in createAppReports()
385 containers.put(attempt.getApplicationAttemptId(), containerReports); in createAppReports() local
|
| H A D | TestYarnClient.java | 611 List<ContainerReport> containerReports = new ArrayList<ContainerReport>(); in createAppReports() local
617 containerReports.add(container); in createAppReports()
624 containerReports.add(container1); in createAppReports()
625 containers.put(attempt.getApplicationAttemptId(), containerReports); in createAppReports() local
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/webapp/ |
| H A D | WebServices.java | 324 Collection<ContainerReport> containerReports = null; in getContainers() local
328 containerReports = in getContainers()
331 containerReports = callerUGI.doAs( in getContainers()
344 for (ContainerReport containerReport : containerReports) { in getContainers()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/ |
| H A D | AbstractYarnScheduler.java | 314 List<NMContainerStatus> containerReports, RMNode nm) { in recoverContainersOnNode() argument
316 || containerReports == null in recoverContainersOnNode()
317 || (containerReports != null && containerReports.isEmpty())) { in recoverContainersOnNode()
321 for (NMContainerStatus container : containerReports) { in recoverContainersOnNode()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/ |
| H A D | MockNM.java | 116 List<NMContainerStatus> containerReports, in registerNode() argument
124 req.setContainerStatuses(containerReports); in registerNode()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/ |
| H A D | NodeStatusUpdaterImpl.java | 255 List<NMContainerStatus> containerReports = getNMContainerStatuses(); in registerWithRM() local
258 nodeManagerVersionId, containerReports, getRunningApplications()); in registerWithRM()
259 if (containerReports != null) { in registerWithRM()
260 LOG.info("Registering with RM using containers :" + containerReports); in registerWithRM()
|