org.apache.hadoop.mapreduce.v2.app.rm

Class MapCollectiveContainerAllocator

java.lang.Object

RMContainerAllocator

org.apache.hadoop.mapreduce.v2.app.rm.MapCollectiveContainerAllocator

public class MapCollectiveContainerAllocator
extends RMContainerAllocator

This class is modified from RMContainerAllocator. Allocates the container from the ResourceManager scheduler.

Constructor Summary

Constructors

Constructor and Description
MapCollectiveContainerAllocator(ClientService clientService, AppContext context)

Method Summary

Modifier and Type	Method and Description
protected void	handleEvent(ContainerAllocatorEvent event) How the event is generated in TaskAttemptImpl: RequestContainerTransition taskAttempt.eventHandler.handle(new ContainerRequestEvent( taskAttempt.attemptId, taskAttempt.resourceCapability, taskAttempt.dataLocalHosts.toArray( new String[taskAttempt.dataLocalHosts.size()]), taskAttempt.dataLocalRacks.toArray( new String[taskAttempt.dataLocalRacks.size()])));
protected void	serviceInit(Configuration conf)

Methods inherited from class java.lang.Object

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

Constructor Detail

MapCollectiveContainerAllocator

public MapCollectiveContainerAllocator(ClientService clientService,
                                       AppContext context)

Method Detail

serviceInit

protected void serviceInit(Configuration conf)
                    throws java.lang.Exception

Throws:

java.lang.Exception

handleEvent

protected void handleEvent(ContainerAllocatorEvent event)

How the event is generated in TaskAttemptImpl: RequestContainerTransition taskAttempt.eventHandler.handle(new ContainerRequestEvent( taskAttempt.attemptId, taskAttempt.resourceCapability, taskAttempt.dataLocalHosts.toArray( new String[taskAttempt.dataLocalHosts.size()]), taskAttempt.dataLocalRacks.toArray( new String[taskAttempt.dataLocalRacks.size()])));