public static class JobImpl.InitTransition extends Object implements MultipleArcTransition<JobImpl,JobEvent,JobStateInternal>
Constructor and Description |
---|
JobImpl.InitTransition() |
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).
|
public JobStateInternal transition(JobImpl job, JobEvent event)
transition
in interface MultipleArcTransition<JobImpl,JobEvent,JobStateInternal>
job
- the entity attached to the FSM, whose internal
state may change.event
- causal eventprotected void setup(JobImpl job) throws IOException
IOException
protected JobSplit.TaskSplitMetaInfo[] createSplits(JobImpl job, JobId jobId)
Copyright © 2013 Apache Software Foundation. All rights reserved.