Uses of Class
org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl
Packages that use JobImpl
-
Uses of JobImpl in org.apache.hadoop.mapreduce.v2.app.job.impl
Fields in org.apache.hadoop.mapreduce.v2.app.job.impl with type parameters of type JobImplModifier and TypeFieldDescriptionprotected static final org.apache.hadoop.yarn.state.StateMachineFactory<JobImpl,JobStateInternal, JobEventType, JobEvent> JobImpl.stateMachineFactoryMethods in org.apache.hadoop.mapreduce.v2.app.job.impl with parameters of type JobImplModifier and TypeMethodDescriptionprotected org.apache.hadoop.mapreduce.split.JobSplit.TaskSplitMetaInfo[]JobImpl.InitTransition.createSplits(JobImpl job, org.apache.hadoop.mapreduce.v2.api.records.JobId jobId) protected voidJobImpl.InitTransition.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).voidJobImpl.StartTransition.transition(JobImpl job, JobEvent event) This transition executes in the event-dispatcher thread, though it's triggered in MRAppMaster's startJobs() method.