程序包 | 说明 |
---|---|
org.apache.hadoop.mapred |
A software framework for easily writing applications which process vast
amounts of data (multi-terabyte data-sets) parallelly on large clusters
(thousands of nodes) built of commodity hardware in a reliable, fault-tolerant
manner.
|
org.apache.hadoop.mapreduce | |
org.apache.hadoop.mapreduce.server.jobtracker | |
org.apache.hadoop.tools.rumen |
Rumen is a data extraction and analysis tool built for
Apache Hadoop.
|
限定符和类型 | 方法和说明 |
---|---|
int |
JobInProgress.getNumSlotsPerTask(TaskType taskType) |
void |
JobInProgress.reserveTaskTracker(TaskTracker taskTracker,
TaskType type,
int numSlots) |
void |
JobInProgress.unreserveTaskTracker(TaskTracker taskTracker,
TaskType type) |
限定符和类型 | 方法和说明 |
---|---|
static TaskType |
TaskType.valueOf(String name)
返回带有指定名称的该类型的枚举常量。
|
static TaskType[] |
TaskType.values()
按照声明该枚举类型的常量的顺序, 返回
包含这些常量的数组。
|
限定符和类型 | 方法和说明 |
---|---|
int |
TaskTracker.getAvailableSlots(TaskType taskType)
Get the number of currently available slots on this tasktracker for the
given type of the task.
|
JobInProgress |
TaskTracker.getJobForFallowSlot(TaskType taskType)
Get the
JobInProgress for which the fallow slot(s) are held. |
void |
TaskTracker.reserveSlots(TaskType taskType,
JobInProgress job,
int numSlots)
Reserve specified number of slots for a given
job . |
void |
TaskTracker.unreserveSlots(TaskType taskType,
JobInProgress job)
Free map slots on this
TaskTracker which were reserved for
taskType . |
限定符和类型 | 方法和说明 |
---|---|
TaskType |
TaskStartedEvent.getTaskType()
Get the task type
|
TaskType |
TaskFinishedEvent.getTaskType()
Get task type
|
TaskType |
TaskFailedEvent.getTaskType()
Get the task type
|
TaskType |
TaskAttemptUnsuccessfulCompletionEvent.getTaskType()
Get the task type
|
TaskType |
TaskAttemptStartedEvent.getTaskType()
Get the task type
|
TaskType |
TaskAttemptFinishedEvent.getTaskType()
Get the task type
|
TaskType |
ReduceAttemptFinishedEvent.getTaskType()
Get the task type
|
TaskType |
MapAttemptFinishedEvent.getTaskType()
Get the task type
|
限定符和类型 | 方法和说明 |
---|---|
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. not needed to make scheduling decisions). |
TaskInfo |
ZombieJob.getTaskInfo(TaskType taskType,
int taskNumber) |
TaskInfo |
JobStory.getTaskInfo(TaskType taskType,
int taskNumber)
Get
TaskInfo for a given task. |
构造器和说明 |
---|
MapAttemptFinishedEvent(TaskAttemptID id,
TaskType taskType,
String taskStatus,
long mapFinishTime,
long finishTime,
String hostname,
String state,
Counters counters)
Create an event for successful completion of map attempts
|
ReduceAttemptFinishedEvent(TaskAttemptID id,
TaskType taskType,
String taskStatus,
long shuffleFinishTime,
long sortFinishTime,
long finishTime,
String hostname,
String state,
Counters counters)
Create an event to record completion of a reduce attempt
|
TaskAttemptFinishedEvent(TaskAttemptID id,
TaskType taskType,
String taskStatus,
long finishTime,
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,
String locality,
String avataar)
Create an event to record the start of an attempt
|
TaskAttemptUnsuccessfulCompletionEvent(TaskAttemptID id,
TaskType taskType,
String status,
long finishTime,
String hostname,
String error)
Create an event to record the unsuccessful completion of attempts
|
TaskFailedEvent(TaskID id,
long finishTime,
TaskType taskType,
String error,
String status,
TaskAttemptID failedDueToAttempt)
Create an event to record task failure
|
TaskFinishedEvent(TaskID id,
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
|
Copyright © 2009 The Apache Software Foundation