public class ContainersMonitorImpl extends org.apache.hadoop.service.AbstractService implements ContainersMonitor
Modifier and Type | Class and Description |
---|---|
static class |
ContainersMonitorImpl.ContainerMetric
Type of container metric.
|
static class |
ContainersMonitorImpl.ProcessTreeInfo
Encapsulates resource requirements of a process and its tree.
|
Constructor and Description |
---|
ContainersMonitorImpl(ContainerExecutor exec,
org.apache.hadoop.yarn.event.AsyncDispatcher dispatcher,
Context context) |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.yarn.api.records.ResourceUtilization |
getContainersUtilization() |
long |
getPmemAllocatedForContainers()
Get physical memory allocated to the containers.
|
long |
getVCoresAllocatedForContainers() |
long |
getVmemAllocatedForContainers()
Get virtual memory allocated to the containers.
|
float |
getVmemRatio() |
void |
handle(ContainersMonitorEvent monitoringEvent) |
boolean |
isPmemCheckEnabled()
Is the total physical memory check enabled?
|
boolean |
isVmemCheckEnabled()
Is the total virtual memory check enabled?
|
protected void |
serviceInit(org.apache.hadoop.conf.Configuration myConf) |
protected void |
serviceStart() |
protected void |
serviceStop() |
void |
setAllocatedResourcesForContainers(org.apache.hadoop.yarn.api.records.Resource resource)
Set the allocated resources for containers.
|
void |
subtractNodeResourcesFromResourceUtilization(org.apache.hadoop.yarn.api.records.ResourceUtilization resourceUtil) |
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
decreaseResourceUtilization, increaseResourceUtilization
public ContainersMonitorImpl(ContainerExecutor exec, org.apache.hadoop.yarn.event.AsyncDispatcher dispatcher, Context context)
protected void serviceInit(org.apache.hadoop.conf.Configuration myConf) throws Exception
serviceInit
in class org.apache.hadoop.service.AbstractService
Exception
protected void serviceStart() throws Exception
serviceStart
in class org.apache.hadoop.service.AbstractService
Exception
protected void serviceStop() throws Exception
serviceStop
in class org.apache.hadoop.service.AbstractService
Exception
public long getVmemAllocatedForContainers()
ResourceView
getVmemAllocatedForContainers
in interface ResourceView
public boolean isPmemCheckEnabled()
isPmemCheckEnabled
in interface ResourceView
public long getPmemAllocatedForContainers()
ResourceView
getPmemAllocatedForContainers
in interface ResourceView
public long getVCoresAllocatedForContainers()
getVCoresAllocatedForContainers
in interface ResourceView
public void setAllocatedResourcesForContainers(org.apache.hadoop.yarn.api.records.Resource resource)
ContainersMonitor
setAllocatedResourcesForContainers
in interface ContainersMonitor
resource
- Resources allocated for the containers.public boolean isVmemCheckEnabled()
isVmemCheckEnabled
in interface ResourceView
public org.apache.hadoop.yarn.api.records.ResourceUtilization getContainersUtilization()
getContainersUtilization
in interface ContainersMonitor
public void subtractNodeResourcesFromResourceUtilization(org.apache.hadoop.yarn.api.records.ResourceUtilization resourceUtil)
subtractNodeResourcesFromResourceUtilization
in interface ContainersMonitor
public float getVmemRatio()
getVmemRatio
in interface ContainersMonitor
public void handle(ContainersMonitorEvent monitoringEvent)
handle
in interface org.apache.hadoop.yarn.event.EventHandler<ContainersMonitorEvent>
Copyright © 2008–2023 Apache Software Foundation. All rights reserved.