程序包 | 说明 |
---|---|
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.
|
限定符和类型 | 类和说明 |
---|---|
class |
TaskTracker
TaskTracker is a process that starts and tracks MR Tasks
in a networked environment.
|
限定符和类型 | 字段和说明 |
---|---|
protected TaskUmbilicalProtocol |
Task.umbilical |
限定符和类型 | 方法和说明 |
---|---|
void |
Task.done(TaskUmbilicalProtocol umbilical,
Task.TaskReporter reporter) |
abstract void |
TaskController.initializeJob(String user,
String jobid,
Path credentials,
Path jobConf,
TaskUmbilicalProtocol taskTracker,
InetSocketAddress ttAddr)
Create all of the directories necessary for the job to start and download
all of the job and private distributed cache files.
|
void |
DefaultTaskController.initializeJob(String user,
String jobid,
Path credentials,
Path jobConf,
TaskUmbilicalProtocol taskTracker,
InetSocketAddress ttAddr)
This routine initializes the local file system for running a job.
|
void |
JobLocalizer.localizeJobFiles(JobID jobid,
JobConf jConf,
Path localJobFile,
Path localJobTokenFile,
TaskUmbilicalProtocol taskTracker) |
void |
JobLocalizer.localizeJobFiles(JobID jobid,
JobConf jConf,
Path localJobTokenFile,
TaskUmbilicalProtocol taskTracker) |
protected void |
Task.reportNextRecordRange(TaskUmbilicalProtocol umbilical,
long nextRecIndex)
Reports the next executing record range to TaskTracker.
|
abstract void |
Task.run(JobConf job,
TaskUmbilicalProtocol umbilical)
Run this task as a part of the named job.
|
protected void |
Task.runJobCleanupTask(TaskUmbilicalProtocol umbilical,
Task.TaskReporter reporter) |
protected void |
Task.runJobSetupTask(TaskUmbilicalProtocol umbilical,
Task.TaskReporter reporter) |
int |
JobLocalizer.runSetup(String user,
String jobid,
Path localJobTokenFile,
TaskUmbilicalProtocol taskTracker) |
protected void |
Task.runTaskCleanupTask(TaskUmbilicalProtocol umbilical,
Task.TaskReporter reporter) |
protected void |
Task.statusUpdate(TaskUmbilicalProtocol umbilical) |
Copyright © 2009 The Apache Software Foundation