public interface ContainerAllocator
Modifier and Type | Method and Description |
---|---|
void |
addListener(ContainerAllocatorListener listener)
Adds the
ContainerAllocatorListener . |
void |
allocateContainers(ContainerAllocateData containerAllocateData)
Allocate new containers.
|
void |
allocateContainers(int count)
Allocate new containers.
|
void |
releaseContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId)
Release container.
|
void |
releaseContainers(java.util.List<org.apache.hadoop.yarn.api.records.Container> containers)
Release containers.
|
void |
setProgress(float progress)
Sets the current progress of application.
|
void allocateContainers(int count)
count
- the new container count to allocatevoid allocateContainers(ContainerAllocateData containerAllocateData)
containerAllocateData
- the ContainerAllocateData
void releaseContainers(java.util.List<org.apache.hadoop.yarn.api.records.Container> containers)
containers
- the containersvoid releaseContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId)
containerId
- the container idvoid addListener(ContainerAllocatorListener listener)
ContainerAllocatorListener
.listener
- the ContainerAllocatorListener
void setProgress(float progress)
progress
- the current progress of application