org.springframework.yarn.am.allocate
Class DefaultContainerAllocator

java.lang.Object
  org.springframework.yarn.support.LifecycleObjectSupport
      org.springframework.yarn.am.allocate.AbstractAllocator
          org.springframework.yarn.am.allocate.AbstractPollingAllocator
              org.springframework.yarn.am.allocate.DefaultContainerAllocator

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.InitializingBean, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle, ContainerAllocator

public class DefaultContainerAllocator
extends AbstractPollingAllocator
implements ContainerAllocator

Default allocator which polls resource manager, requests new containers and acts as a heart beat sender at the same time.

Author:

Janne Valkealahti

Constructor Summary

DefaultContainerAllocator()

Method Summary

void	addListener(ContainerAllocatorListener listener) Adds the ContainerAllocatorListener.
void	allocateContainers(ContainerAllocateData containerAllocateData) Allocate new containers.
void	allocateContainers(int count) Allocate new containers.
protected org.apache.hadoop.yarn.api.records.AMResponse	doContainerRequest() Subclasses needs to implements this method to do container requests against resource manager.
java.lang.String[]	getHosts() Gets the hosts.
int	getMemory() Gets the memory for container request.
int	getPriority() Gets the priority for container request.
java.lang.String[]	getRacks() Gets the racks.
int	getVirtualcores() Gets the virtualcores for container request.
protected void	handleAllocatedContainers(java.util.List<org.apache.hadoop.yarn.api.records.Container> containers) Subclasses needs to implement this method to handle newly allocated containers.
protected void	handleCompletedContainers(java.util.List<org.apache.hadoop.yarn.api.records.ContainerStatus> containerStatuses) Subclasses needs to implement this method to handle newly released containers.
protected java.util.List<org.apache.hadoop.yarn.api.records.Container>	preProcessAllocatedContainers(java.util.List<org.apache.hadoop.yarn.api.records.Container> containers) Pre process allocated 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	setHosts(java.lang.String[] hosts) Sets the hosts.
void	setMemory(int memory) Sets the memory for container request defining memory of the resource.
void	setPriority(int priority) Sets the priority for container request.
void	setProgress(float progress) Sets the current progress of application.
void	setRacks(java.lang.String[] racks) Sets the racks.
void	setVirtualcores(int virtualcores) Sets the virtualcores for container request defining number of virtual cpu cores of the resource.

Methods inherited from class org.springframework.yarn.am.allocate.AbstractPollingAllocator

doStart, doStop, onInit, setTrigger

Methods inherited from class org.springframework.yarn.am.allocate.AbstractAllocator

getApplicationAttemptId, getConfiguration, getEnvironment, getRmTemplate, setApplicationAttemptId, setConfiguration, setEnvironment, setRmTemplate

Methods inherited from class org.springframework.yarn.support.LifecycleObjectSupport

afterPropertiesSet, getBeanFactory, getPhase, getTaskExecutor, getTaskScheduler, getYarnEventPublisher, isAutoStartup, isRunning, setAutoStartup, setBeanFactory, setPhase, setTaskExecutor, setTaskScheduler, setYarnEventPublisher, start, stop, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultContainerAllocator

public DefaultContainerAllocator()

Method Detail

allocateContainers

public void allocateContainers(int count)

Description copied from interface: ContainerAllocator

Allocate new containers.

Specified by:

allocateContainers in interface ContainerAllocator

Parameters:

count - the new container count to allocate

addListener

public void addListener(ContainerAllocatorListener listener)

Description copied from interface: ContainerAllocator

Adds the ContainerAllocatorListener.

Specified by:

addListener in interface ContainerAllocator

Parameters:

listener - the ContainerAllocatorListener

allocateContainers

public void allocateContainers(ContainerAllocateData containerAllocateData)

Description copied from interface: ContainerAllocator

Allocate new containers.

Specified by:

allocateContainers in interface ContainerAllocator

Parameters:

containerAllocateData - the ContainerAllocateData

releaseContainers

public void releaseContainers(java.util.List<org.apache.hadoop.yarn.api.records.Container> containers)

Description copied from interface: ContainerAllocator

Release containers.

Specified by:

releaseContainers in interface ContainerAllocator

Parameters:

containers - the containers

releaseContainer

public void releaseContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId)

Description copied from interface: ContainerAllocator

Release container.

Specified by:

releaseContainer in interface ContainerAllocator

Parameters:

containerId - the container id

doContainerRequest

protected org.apache.hadoop.yarn.api.records.AMResponse doContainerRequest()

Description copied from class: AbstractPollingAllocator

Subclasses needs to implements this method to do container requests against resource manager. This method is called during the polling cycle handled by this class. New containers and newly released containers are passed to methods AbstractPollingAllocator.handleAllocatedContainers(List) and AbstractPollingAllocator.handleCompletedContainers(List).

Specified by:

doContainerRequest in class AbstractPollingAllocator

Returns:

AMResponse from a resource manager

preProcessAllocatedContainers

protected java.util.List<org.apache.hadoop.yarn.api.records.Container> preProcessAllocatedContainers(java.util.List<org.apache.hadoop.yarn.api.records.Container> containers)

Description copied from class: AbstractPollingAllocator

Pre process allocated containers. Allows implementors to intercept containers before further processing is done. Default implementation returns list as it is.

Overrides:

preProcessAllocatedContainers in class AbstractPollingAllocator

Parameters:

containers - the containers

Returns:

the list of containers

handleAllocatedContainers

protected void handleAllocatedContainers(java.util.List<org.apache.hadoop.yarn.api.records.Container> containers)

Description copied from class: AbstractPollingAllocator

Subclasses needs to implement this method to handle newly allocated containers.

Specified by:

handleAllocatedContainers in class AbstractPollingAllocator

Parameters:

containers - list of newly allocate containers

handleCompletedContainers

protected void handleCompletedContainers(java.util.List<org.apache.hadoop.yarn.api.records.ContainerStatus> containerStatuses)

Description copied from class: AbstractPollingAllocator

Subclasses needs to implement this method to handle newly released containers.

Specified by:

handleCompletedContainers in class AbstractPollingAllocator

Parameters:

containerStatuses - list of newly released containers

setProgress

public void setProgress(float progress)

Description copied from interface: ContainerAllocator

Sets the current progress of application.

Specified by:

setProgress in interface ContainerAllocator

Parameters:

progress - the current progress of application

getPriority

public int getPriority()

Gets the priority for container request.

Returns:

the priority

setPriority

public void setPriority(int priority)

Sets the priority for container request.

Parameters:

priority - the new priority

getHosts

public java.lang.String[] getHosts()

Gets the hosts.

Returns:

the hosts

setHosts

public void setHosts(java.lang.String[] hosts)

Sets the hosts.

Parameters:

hosts - the new hosts

getRacks

public java.lang.String[] getRacks()

Gets the racks.

Returns:

the racks

setRacks

public void setRacks(java.lang.String[] racks)

Sets the racks.

Parameters:

racks - the new racks

getVirtualcores

public int getVirtualcores()

Gets the virtualcores for container request.

Returns:

the virtualcores

setVirtualcores

public void setVirtualcores(int virtualcores)

Sets the virtualcores for container request defining number of virtual cpu cores of the resource.

Parameters:

virtualcores - the new virtualcores

getMemory

public int getMemory()

Gets the memory for container request.

Returns:

the memory

setMemory

public void setMemory(int memory)

Sets the memory for container request defining memory of the resource.

Parameters:

memory - the new memory