public class JobImpl extends Object implements Job, EventHandler<JobEvent>
Modifier and Type | Class and Description |
---|---|
static class |
JobImpl.InitTransition |
static class |
JobImpl.StartTransition |
Modifier and Type | Field and Description |
---|---|
JobConf |
conf |
Path |
remoteJobConfFile |
protected static StateMachineFactory<JobImpl,JobStateInternal,JobEventType,JobEvent> |
stateMachineFactory |
Constructor and Description |
---|
JobImpl(JobId jobId,
ApplicationAttemptId applicationAttemptId,
Configuration conf,
EventHandler eventHandler,
TaskAttemptListener taskAttemptListener,
JobTokenSecretManager jobTokenSecretManager,
Credentials jobCredentials,
Clock clock,
Map<TaskId,JobHistoryParser.TaskInfo> completedTasksFromPreviousRun,
MRAppMetrics metrics,
OutputCommitter committer,
boolean newApiCommitter,
String userName,
long appSubmitTime,
List<AMInfo> amInfos,
AppContext appContext,
JobStateInternal forcedState,
String forcedDiagnostic) |
public JobConf conf
public Path remoteJobConfFile
protected static final StateMachineFactory<JobImpl,JobStateInternal,JobEventType,JobEvent> stateMachineFactory
public JobImpl(JobId jobId, ApplicationAttemptId applicationAttemptId, Configuration conf, EventHandler eventHandler, TaskAttemptListener taskAttemptListener, JobTokenSecretManager jobTokenSecretManager, Credentials jobCredentials, Clock clock, Map<TaskId,JobHistoryParser.TaskInfo> completedTasksFromPreviousRun, MRAppMetrics metrics, OutputCommitter committer, boolean newApiCommitter, String userName, long appSubmitTime, List<AMInfo> amInfos, AppContext appContext, JobStateInternal forcedState, String forcedDiagnostic)
protected StateMachine<JobStateInternal,JobEventType,JobEvent> getStateMachine()
public boolean checkAccess(UserGroupInformation callerUGI, JobACL jobOperation)
checkAccess
in interface Job
public int getCompletedMaps()
getCompletedMaps
in interface Job
public int getCompletedReduces()
getCompletedReduces
in interface Job
public Counters getAllCounters()
Job
getAllCounters
in interface Job
public static Counters incrTaskCounters(Counters counters, Collection<Task> tasks)
public TaskAttemptCompletionEvent[] getTaskAttemptCompletionEvents(int fromEventId, int maxEvents)
getTaskAttemptCompletionEvents
in interface Job
public TaskCompletionEvent[] getMapAttemptCompletionEvents(int startIndex, int maxEvents)
getMapAttemptCompletionEvents
in interface Job
public List<String> getDiagnostics()
getDiagnostics
in interface Job
public float getProgress()
getProgress
in interface Job
public void handle(JobEvent event)
handle
in interface EventHandler<JobEvent>
@InterfaceAudience.Private public JobStateInternal getInternalState()
protected void addTask(Task task)
protected FileSystem getFileSystem(Configuration conf) throws IOException
conf
- the conf objectIOException
protected JobStateInternal checkReadyForCommit()
public String getUserName()
getUserName
in interface Job
public String getQueueName()
getQueueName
in interface Job
public Path getConfFile()
getConfFile
in interface Job
public int getTotalMaps()
getTotalMaps
in interface Job
public int getTotalReduces()
getTotalReduces
in interface Job
public Map<JobACL,AccessControlList> getJobACLs()
getJobACLs
in interface Job
public List<AMInfo> getAMInfos()
getAMInfos
in interface Job
@InterfaceAudience.Private public void constructFinalFullcounters()
protected void addDiagnostic(String diag)
public Configuration loadConfFile() throws IOException
loadConfFile
in interface Job
Job.getConfFile()
.IOException
- on any error trying to load the conf file.Copyright © 2013 Apache Software Foundation. All rights reserved.