org.apache.hadoop.mapreduce.v2.app

Class MapCollectiveAppMaster

java.lang.Object

MRAppMaster

org.apache.hadoop.mapreduce.v2.app.MapCollectiveAppMaster

public class MapCollectiveAppMaster
extends MRAppMaster

The Map-Reduce Application Master. The state machine is encapsulated in the implementation of Job interface. All state changes happens via Job interface. Each event results in a Finite State Transition in Job. MR AppMaster is the composition of loosely coupled services. The services interact with each other via events. The components resembles the Actors model. The component acts on received event and send out the events to other components. This keeps it highly concurrent with no or minimal synchronization needs. The events are dispatched by a central Dispatch mechanism. All components register to the Dispatcher. The information is shared across different components using AppContext.

Constructor Summary

Constructors

Constructor and Description
MapCollectiveAppMaster(ApplicationAttemptId applicationAttemptId, ContainerId containerId, java.lang.String nmHost, int nmPort, int nmHttpPort, long appSubmitTime)

Method Summary

Modifier and Type	Method and Description
protected ContainerAllocator	createContainerAllocator(ClientService clientService, AppContext context)
protected ContainerLauncher	createContainerLauncher(AppContext context)
static void	main(java.lang.String[] args)
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

MapCollectiveAppMaster

public MapCollectiveAppMaster(ApplicationAttemptId applicationAttemptId,
                              ContainerId containerId,
                              java.lang.String nmHost,
                              int nmPort,
                              int nmHttpPort,
                              long appSubmitTime)

Method Detail

serviceInit

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

Throws:

java.lang.Exception

createContainerAllocator

protected ContainerAllocator createContainerAllocator(ClientService clientService,
                                                      AppContext context)

createContainerLauncher

protected ContainerLauncher createContainerLauncher(AppContext context)

main

public static void main(java.lang.String[] args)