public static class JobImpl.InitTransition extends Object implements org.apache.hadoop.yarn.state.MultipleArcTransition<JobImpl,JobEvent,JobStateInternal>
Constructor and Description |
---|
InitTransition() |
Modifier and Type | Method and Description |
---|---|
protected org.apache.hadoop.mapreduce.split.JobSplit.TaskSplitMetaInfo[] |
createSplits(JobImpl job,
org.apache.hadoop.mapreduce.v2.api.records.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 org.apache.hadoop.yarn.state.MultipleArcTransition<JobImpl,JobEvent,JobStateInternal>
protected void setup(JobImpl job) throws IOException
IOException
protected org.apache.hadoop.mapreduce.split.JobSplit.TaskSplitMetaInfo[] createSplits(JobImpl job, org.apache.hadoop.mapreduce.v2.api.records.JobId jobId)
Copyright © 2008–2024 Apache Software Foundation. All rights reserved.