Package | Description |
---|---|
org.apache.hadoop.mapred | |
org.apache.hadoop.mapreduce | |
org.apache.hadoop.mapreduce.jobhistory | |
org.apache.hadoop.mapreduce.protocol | |
org.apache.hadoop.tools.rumen |
Rumen is a data extraction and analysis tool built for
Apache Hadoop.
|
Modifier and Type | Method and Description |
---|---|
static String |
TaskAttemptID.getTaskAttemptIDsPattern(String jtIdentifier,
Integer jobId,
TaskType type,
Integer taskId,
Integer attemptId)
Deprecated.
|
static String |
TaskID.getTaskIDsPattern(String jtIdentifier,
Integer jobId,
TaskType type,
Integer taskId)
Deprecated.
|
TaskReport[] |
YARNRunner.getTaskReports(JobID jobID,
TaskType taskType) |
TaskReport[] |
ClientServiceDelegate.getTaskReports(JobID oldJobID,
TaskType taskType) |
TaskReport[] |
LocalJobRunner.getTaskReports(JobID id,
TaskType type) |
Constructor and Description |
---|
TaskAttemptID(String jtIdentifier,
int jobId,
TaskType type,
int taskId,
int id)
Constructs a TaskId object from given parts.
|
TaskID(JobID jobId,
TaskType type,
int id)
Constructs a TaskID object from given
JobID . |
TaskID(String jtIdentifier,
int jobId,
TaskType type,
int id)
Constructs a TaskInProgressId object from given parts.
|
Modifier and Type | Method and Description |
---|---|
static TaskType |
TypeConverter.fromYarn(TaskType taskType) |
TaskType |
TaskAttemptID.getTaskType()
Returns the TaskType of the TaskAttemptID
|
TaskType |
TaskID.getTaskType()
Get the type of the task
|
static TaskType |
TaskID.getTaskType(char c)
Gets the
TaskType corresponding to the character |
static TaskType |
TaskType.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static TaskType[] |
TaskType.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
static char |
TaskID.getRepresentingCharacter(TaskType type)
Gets the character representing the
TaskType |
TaskReport[] |
Job.getTaskReports(TaskType type)
Get the information of the current state of the tasks of a job.
|
static TaskType |
TypeConverter.toYarn(TaskType taskType) |
Constructor and Description |
---|
TaskAttemptID(String jtIdentifier,
int jobId,
TaskType type,
int taskId,
int id)
Constructs a TaskId object from given parts.
|
TaskID(JobID jobId,
TaskType type,
int id)
Constructs a TaskID object from given
JobID . |
TaskID(String jtIdentifier,
int jobId,
TaskType type,
int id)
Constructs a TaskInProgressId object from given parts.
|
Modifier and Type | Method and Description |
---|---|
TaskType |
TaskStartedEvent.getTaskType()
Get the task type
|
TaskType |
TaskAttemptFinishedEvent.getTaskType()
Get the task type
|
TaskType |
TaskFailedEvent.getTaskType()
Get the task type
|
TaskType |
NormalizedResourceEvent.getTaskType()
the tasktype for the event.
|
TaskType |
MapAttemptFinishedEvent.getTaskType()
Get the task type
|
TaskType |
ReduceAttemptFinishedEvent.getTaskType()
Get the task type
|
TaskType |
TaskAttemptUnsuccessfulCompletionEvent.getTaskType()
Get the task type
|
TaskType |
TaskAttemptStartedEvent.getTaskType()
Get the task type
|
TaskType |
TaskFinishedEvent.getTaskType()
Get task type
|
TaskType |
JobHistoryParser.TaskInfo.getTaskType() |
TaskType |
JobHistoryParser.TaskAttemptInfo.getTaskType() |
Constructor and Description |
---|
MapAttemptFinishedEvent(TaskAttemptID id,
TaskType taskType,
String taskStatus,
long mapFinishTime,
long finishTime,
String hostname,
int port,
String rackName,
String state,
Counters counters,
int[][] allSplits)
Create an event for successful completion of map attempts
|
MapAttemptFinishedEvent(TaskAttemptID id,
TaskType taskType,
String taskStatus,
long mapFinishTime,
long finishTime,
String hostname,
String state,
Counters counters)
Deprecated.
please use the constructor with an additional
argument, an array of splits arrays instead. See
ProgressSplitsBlock
for an explanation of the meaning of that parameter.
Create an event for successful completion of map attempts |
NormalizedResourceEvent(TaskType taskType,
int memory)
Normalized request when sent to the Resource Manager.
|
ReduceAttemptFinishedEvent(TaskAttemptID id,
TaskType taskType,
String taskStatus,
long shuffleFinishTime,
long sortFinishTime,
long finishTime,
String hostname,
int port,
String rackName,
String state,
Counters counters,
int[][] allSplits)
Create an event to record completion of a reduce attempt
|
ReduceAttemptFinishedEvent(TaskAttemptID id,
TaskType taskType,
String taskStatus,
long shuffleFinishTime,
long sortFinishTime,
long finishTime,
String hostname,
String state,
Counters counters)
Deprecated.
please use the constructor with an additional
argument, an array of splits arrays instead. See
ProgressSplitsBlock
for an explanation of the meaning of that parameter.
Create an event to record completion of a reduce attempt |
TaskAttemptFinishedEvent(TaskAttemptID id,
TaskType taskType,
String taskStatus,
long finishTime,
String rackName,
String hostname,
String state,
Counters counters)
Create an event to record successful finishes for setup and cleanup
attempts
|
TaskAttemptStartedEvent(TaskAttemptID attemptId,
TaskType taskType,
long startTime,
String trackerName,
int httpPort,
int shufflePort,
ContainerId containerId,
String locality,
String avataar)
Create an event to record the start of an attempt
|
TaskAttemptStartedEvent(TaskAttemptID attemptId,
TaskType taskType,
long startTime,
String trackerName,
int httpPort,
int shufflePort,
String locality,
String avataar) |
TaskAttemptUnsuccessfulCompletionEvent(TaskAttemptID id,
TaskType taskType,
String status,
long finishTime,
String hostname,
int port,
String rackName,
String error,
Counters counters,
int[][] allSplits)
Create an event to record the unsuccessful completion of attempts
|
TaskAttemptUnsuccessfulCompletionEvent(TaskAttemptID id,
TaskType taskType,
String status,
long finishTime,
String hostname,
int port,
String rackName,
String error,
int[][] allSplits) |
TaskAttemptUnsuccessfulCompletionEvent(TaskAttemptID id,
TaskType taskType,
String status,
long finishTime,
String hostname,
String error)
Deprecated.
please use the constructor with an additional
argument, an array of splits arrays instead. See
ProgressSplitsBlock
for an explanation of the meaning of that parameter.
Create an event to record the unsuccessful completion of attempts |
TaskFailedEvent(TaskID id,
long finishTime,
TaskType taskType,
String error,
String status,
TaskAttemptID failedDueToAttempt) |
TaskFailedEvent(TaskID id,
long finishTime,
TaskType taskType,
String error,
String status,
TaskAttemptID failedDueToAttempt,
Counters counters)
Create an event to record task failure
|
TaskFinishedEvent(TaskID id,
TaskAttemptID attemptId,
long finishTime,
TaskType taskType,
String status,
Counters counters)
Create an event to record the successful completion of a task
|
TaskStartedEvent(TaskID id,
long startTime,
TaskType taskType,
String splitLocations)
Create an event to record start of a task
|
Modifier and Type | Method and Description |
---|---|
TaskReport[] |
ClientProtocol.getTaskReports(JobID jobid,
TaskType type)
Grab a bunch of info on the tasks that make up the job
|
Modifier and Type | Method and Description |
---|---|
TaskAttemptInfo |
ZombieJob.getTaskAttemptInfo(TaskType taskType,
int taskNumber,
int taskAttemptNumber)
Get a
TaskAttemptInfo with a TaskAttemptID associated with
taskType, taskNumber, and taskAttemptNumber. |
TaskAttemptInfo |
JobStory.getTaskAttemptInfo(TaskType taskType,
int taskNumber,
int taskAttemptNumber)
Get
TaskAttemptInfo for a given task-attempt, without regard to
impact of locality (e.g. |
TaskInfo |
ZombieJob.getTaskInfo(TaskType taskType,
int taskNumber) |
TaskInfo |
JobStory.getTaskInfo(TaskType taskType,
int taskNumber)
Get
TaskInfo for a given task. |
Copyright © 2013 Apache Software Foundation. All rights reserved.