org.apache.hadoop.mapreduce.v2.app.job.impl

Class JobImpl.InitTransition

java.lang.Object

org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl.InitTransition

All Implemented Interfaces:

MultipleArcTransition<JobImpl,JobEvent,JobStateInternal>

Enclosing class:

JobImpl

public static class JobImpl.InitTransition
extends Object
implements MultipleArcTransition<JobImpl,JobEvent,JobStateInternal>

Constructor Summary

Constructors

Constructor and Description
JobImpl.InitTransition()

Method Summary

Methods

Modifier and Type	Method and Description
protected JobSplit.TaskSplitMetaInfo[]	createSplits(JobImpl job, JobId jobId)
protected void	setup(JobImpl job)
JobStateInternal	transition(JobImpl job, JobEvent event) Note that this transition method is called directly (and synchronously) by MRAppMaster's init() method (i.e., no RPC, no thread-switching; just plain sequential call within AM context), so we can trigger modifications in AM state from here (at least, if AM is written that way; MR version is).

Methods inherited from class java.lang.Object

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

Constructor Detail

JobImpl.InitTransition

public JobImpl.InitTransition()

Method Detail

transition

public JobStateInternal transition(JobImpl job,
                          JobEvent event)

Note that this transition method is called directly (and synchronously) by MRAppMaster's init() method (i.e., no RPC, no thread-switching; just plain sequential call within AM context), so we can trigger modifications in AM state from here (at least, if AM is written that way; MR version is).

Specified by:

transition in interface MultipleArcTransition<JobImpl,JobEvent,JobStateInternal>

Parameters:

job - the entity attached to the FSM, whose internal state may change.

event - causal event

Returns:

the postState. Post state must be one of the valid post states registered in StateMachine.

setup

protected void setup(JobImpl job)
              throws IOException

Throws:

IOException

createSplits

protected JobSplit.TaskSplitMetaInfo[] createSplits(JobImpl job,
                                        JobId jobId)