Modifier and Type | Method and Description |
---|---|
static JobId |
TypeConverter.toYarn(JobID id) |
Modifier and Type | Method and Description |
---|---|
static JobID |
TypeConverter.fromYarn(JobId id) |
Modifier and Type | Field and Description |
---|---|
protected static Map<JobId,JobHistoryEventHandler.MetaInfo> |
JobHistoryEventHandler.fileMap |
Modifier and Type | Method and Description |
---|---|
JobId |
JobSummary.getJobId() |
JobId |
JobHistoryEvent.getJobID() |
Modifier and Type | Method and Description |
---|---|
protected void |
JobHistoryEventHandler.closeEventWriter(JobId jobId) |
void |
JobHistoryEventHandler.closeWriter(JobId id)
Close the event writer for this id
|
protected void |
JobHistoryEventHandler.processDoneFiles(JobId jobId) |
void |
JobHistoryEventHandler.processEventForJobSummary(HistoryEvent event,
JobSummary summary,
JobId jobId) |
void |
JobSummary.setJobId(JobId jobId) |
protected void |
JobHistoryEventHandler.setupEventWriter(JobId jobId)
Create an event writer for the Job represented by the jobID.
|
Constructor and Description |
---|
JobHistoryEvent(JobId jobID,
HistoryEvent historyEvent) |
Modifier and Type | Method and Description |
---|---|
JobId |
GetTaskAttemptCompletionEventsRequest.getJobId() |
JobId |
GetJobReportRequest.getJobId() |
JobId |
KillJobRequest.getJobId() |
JobId |
GetTaskReportsRequest.getJobId() |
JobId |
GetCountersRequest.getJobId() |
Modifier and Type | Method and Description |
---|---|
void |
GetTaskAttemptCompletionEventsRequest.setJobId(JobId jobId) |
void |
GetJobReportRequest.setJobId(JobId jobId) |
void |
KillJobRequest.setJobId(JobId jobId) |
void |
GetTaskReportsRequest.setJobId(JobId jobId) |
void |
GetCountersRequest.setJobId(JobId jobId) |
Modifier and Type | Method and Description |
---|---|
JobId |
GetCountersRequestPBImpl.getJobId() |
JobId |
GetTaskReportsRequestPBImpl.getJobId() |
JobId |
GetJobReportRequestPBImpl.getJobId() |
JobId |
KillJobRequestPBImpl.getJobId() |
JobId |
GetTaskAttemptCompletionEventsRequestPBImpl.getJobId() |
Modifier and Type | Method and Description |
---|---|
void |
GetCountersRequestPBImpl.setJobId(JobId jobId) |
void |
GetTaskReportsRequestPBImpl.setJobId(JobId jobId) |
void |
GetJobReportRequestPBImpl.setJobId(JobId jobId) |
void |
KillJobRequestPBImpl.setJobId(JobId jobId) |
void |
GetTaskAttemptCompletionEventsRequestPBImpl.setJobId(JobId jobId) |
Modifier and Type | Method and Description |
---|---|
abstract JobId |
TaskId.getJobId() |
JobId |
JobReport.getJobId() |
Modifier and Type | Method and Description |
---|---|
int |
JobId.compareTo(JobId other) |
abstract void |
TaskId.setJobId(JobId jobId) |
void |
JobReport.setJobId(JobId jobId) |
Modifier and Type | Class and Description |
---|---|
class |
JobIdPBImpl |
Modifier and Type | Method and Description |
---|---|
JobId |
TaskIdPBImpl.getJobId() |
JobId |
JobReportPBImpl.getJobId() |
Modifier and Type | Method and Description |
---|---|
void |
TaskIdPBImpl.setJobId(JobId jobId) |
void |
JobReportPBImpl.setJobId(JobId jobId) |
Modifier and Type | Method and Description |
---|---|
JobId |
MRAppMaster.getJobId() |
Modifier and Type | Method and Description |
---|---|
Map<JobId,Job> |
AppContext.getAllJobs() |
Map<JobId,Job> |
MRAppMaster.RunningAppContext.getAllJobs() |
Modifier and Type | Method and Description |
---|---|
Job |
AppContext.getJob(JobId jobID) |
Job |
MRAppMaster.RunningAppContext.getJob(JobId jobID) |
Modifier and Type | Method and Description |
---|---|
JobId |
CommitterJobCommitEvent.getJobID() |
JobId |
CommitterJobAbortEvent.getJobID() |
JobId |
CommitterJobSetupEvent.getJobID() |
Constructor and Description |
---|
CommitterJobAbortEvent(JobId jobID,
JobContext jobContext,
JobStatus.State finalState) |
CommitterJobCommitEvent(JobId jobID,
JobContext jobContext) |
CommitterJobSetupEvent(JobId jobID,
JobContext jobContext) |
Modifier and Type | Method and Description |
---|---|
JobId |
Job.getID() |
Modifier and Type | Method and Description |
---|---|
JobId |
JobFinishEvent.getJobId() |
JobId |
JobEvent.getJobId() |
Constructor and Description |
---|
JobAbortCompletedEvent(JobId jobID,
JobStatus.State finalState) |
JobCommitCompletedEvent(JobId jobID) |
JobCommitFailedEvent(JobId jobID,
String message) |
JobCounterUpdateEvent(JobId jobId) |
JobDiagnosticsUpdateEvent(JobId jobID,
String diagnostic) |
JobEvent(JobId jobID,
JobEventType type) |
JobFinishEvent(JobId jobID) |
JobSetupCompletedEvent(JobId jobID) |
JobSetupFailedEvent(JobId jobID,
String message) |
JobStartEvent(JobId jobID) |
JobStartEvent(JobId jobID,
long recoveredJobStartTime) |
JobUpdatedNodesEvent(JobId jobId,
List<NodeReport> updatedNodes) |
Modifier and Type | Method and Description |
---|---|
JobId |
JobImpl.getID() |
Modifier and Type | Method and Description |
---|---|
protected JobSplit.TaskSplitMetaInfo[] |
JobImpl.InitTransition.createSplits(JobImpl job,
JobId jobId) |
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) |
MapTaskImpl(JobId jobId,
int partition,
EventHandler eventHandler,
Path remoteJobConfFile,
JobConf conf,
JobSplit.TaskSplitMetaInfo taskSplitMetaInfo,
TaskAttemptListener taskAttemptListener,
Token<JobTokenIdentifier> jobToken,
Credentials credentials,
Clock clock,
int appAttemptId,
MRAppMetrics metrics,
AppContext appContext) |
ReduceTaskImpl(JobId jobId,
int partition,
EventHandler eventHandler,
Path jobFile,
JobConf conf,
int numMapTasks,
TaskAttemptListener taskAttemptListener,
Token<JobTokenIdentifier> jobToken,
Credentials credentials,
Clock clock,
int appAttemptId,
MRAppMetrics metrics,
AppContext appContext) |
TaskImpl(JobId jobId,
TaskType taskType,
int partition,
EventHandler eventHandler,
Path remoteJobConfFile,
JobConf conf,
TaskAttemptListener taskAttemptListener,
Token<JobTokenIdentifier> jobToken,
Credentials credentials,
Clock clock,
int appAttemptId,
MRAppMetrics metrics,
AppContext appContext) |
Modifier and Type | Method and Description |
---|---|
JobId |
SpeculatorEvent.getJobID() |
Constructor and Description |
---|
SpeculatorEvent(JobId jobID,
long timestamp) |
Modifier and Type | Method and Description |
---|---|
JobId |
CompletedJob.getID() |
JobId |
PartialJob.getID() |
JobId |
HistoryFileManager.HistoryFileInfo.getJobId() |
Modifier and Type | Method and Description |
---|---|
Map<JobId,Job> |
JobHistory.getAllJobs() |
Map<JobId,Job> |
HistoryContext.getAllJobs(ApplicationId appID) |
Map<JobId,Job> |
JobHistory.getAllJobs(ApplicationId appID) |
Map<JobId,Job> |
HistoryStorage.getAllPartialJobs()
Get all of the cached jobs.
|
Map<JobId,Job> |
CachedHistoryStorage.getAllPartialJobs() |
Modifier and Type | Method and Description |
---|---|
HistoryFileManager.HistoryFileInfo |
HistoryFileManager.getFileInfo(JobId jobId) |
Job |
HistoryStorage.getFullJob(JobId jobId)
Get a fully parsed job.
|
Job |
CachedHistoryStorage.getFullJob(JobId jobId) |
Job |
JobHistory.getJob(JobId jobId) |
Constructor and Description |
---|
CompletedJob(Configuration conf,
JobId jobId,
Path historyFile,
boolean loadTasks,
String userName,
HistoryFileManager.HistoryFileInfo info,
JobACLsManager aclsMgr) |
PartialJob(JobIndexInfo jobIndexInfo,
JobId jobId) |
Modifier and Type | Method and Description |
---|---|
JobId |
JobIndexInfo.getJobId() |
Modifier and Type | Method and Description |
---|---|
static String |
JobHistoryUtils.getIntermediateConfFileName(JobId jobId)
Get the done configuration file name for a job.
|
static String |
JobHistoryUtils.getIntermediateSummaryFileName(JobId jobId)
Get the done summary file name for a job.
|
static Path |
JobHistoryUtils.getStagingConfFile(Path logDir,
JobId jobId,
int attempt)
Gets the conf file path for jobs in progress.
|
static Path |
JobHistoryUtils.getStagingJobHistoryFile(Path dir,
JobId jobId,
int attempt)
Get the job history file path for non Done history files.
|
static String |
JobHistoryUtils.historyLogSubdirectory(JobId id,
String timestampComponent,
String serialNumberFormat)
Gets the history subdirectory based on the jobId, timestamp and serial number format.
|
static int |
JobHistoryUtils.jobSerialNumber(JobId id)
Computes a serial number used as part of directory naming for the given jobId.
|
static String |
JobHistoryUtils.serialNumberDirectoryComponent(JobId id,
String serialNumberFormat)
Gets the serial number part of the path based on the jobId and serialNumber format.
|
void |
JobIndexInfo.setJobId(JobId jobId) |
Constructor and Description |
---|
JobIndexInfo(long submitTime,
long finishTime,
String user,
String jobName,
JobId jobId,
int numMaps,
int numReduces,
String jobStatus) |
Modifier and Type | Method and Description |
---|---|
static JobId |
MRBuilderUtils.newJobId(ApplicationId appId,
int id) |
static JobId |
MRBuilderUtils.newJobId(long clusterTs,
int appIdInt,
int id) |
static JobId |
MRApps.toJobID(String jid) |
Modifier and Type | Method and Description |
---|---|
static Path |
MRApps.getEndJobCommitFailureFile(Configuration conf,
String user,
JobId jobId) |
static Path |
MRApps.getEndJobCommitSuccessFile(Configuration conf,
String user,
JobId jobId) |
static Path |
MRApps.getStartJobCommitFile(Configuration conf,
String user,
JobId jobId) |
static JobReport |
MRBuilderUtils.newJobReport(JobId jobId,
String jobName,
String userName,
JobState state,
long submitTime,
long startTime,
long finishTime,
float setupProgress,
float mapProgress,
float reduceProgress,
float cleanupProgress,
String jobFile,
List<AMInfo> amInfos,
boolean isUber,
String diagnostics) |
static TaskId |
MRBuilderUtils.newTaskId(JobId jobId,
int id,
TaskType taskType) |
static String |
MRApps.toString(JobId jid) |
Copyright © 2013 Apache Software Foundation. All rights reserved.