org.springframework.yarn.listener

Class CompositeContainerAllocatorListener

java.lang.Object

org.springframework.yarn.listener.AbstractCompositeListener<ContainerAllocatorListener>

org.springframework.yarn.listener.CompositeContainerAllocatorListener

All Implemented Interfaces:

ContainerAllocatorListener

public class CompositeContainerAllocatorListener
extends AbstractCompositeListener<ContainerAllocatorListener>
implements ContainerAllocatorListener

Composite listener for handling allocation events.

Author:

Janne Valkealahti

Constructor Summary

Constructors

Constructor and Description
CompositeContainerAllocatorListener()

Method Summary

Methods

Modifier and Type	Method and Description
void	allocated(java.util.List<org.apache.hadoop.yarn.api.records.Container> allocatedContainers) Invoked when new containers are allocated.
void	completed(java.util.List<org.apache.hadoop.yarn.api.records.ContainerStatus> completedContainers) Invoked when containers are releases and thus marked as completed.

Methods inherited from class org.springframework.yarn.listener.AbstractCompositeListener

getListeners, register, setListeners

Methods inherited from class java.lang.Object

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

Constructor Detail

CompositeContainerAllocatorListener

public CompositeContainerAllocatorListener()

Method Detail

allocated

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

Description copied from interface: ContainerAllocatorListener

Invoked when new containers are allocated.

Specified by:

allocated in interface ContainerAllocatorListener

Parameters:

allocatedContainers - list of allocated Containers

completed

public void completed(java.util.List<org.apache.hadoop.yarn.api.records.ContainerStatus> completedContainers)

Description copied from interface: ContainerAllocatorListener

Invoked when containers are releases and thus marked as completed.

Specified by:

completed in interface ContainerAllocatorListener

Parameters:

completedContainers - list of completed ContainerStatuss