Uses of Interface
org.apache.hadoop.mapred.TaskUmbilicalProtocol

Packages that use TaskUmbilicalProtocol

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.

Uses of TaskUmbilicalProtocol in org.apache.hadoop.mapred

Classes in org.apache.hadoop.mapred that implement TaskUmbilicalProtocol

class

TaskTracker TaskTracker is a process that starts and tracks MR Tasks in a networked environment.

Fields in org.apache.hadoop.mapred declared as TaskUmbilicalProtocol

protected TaskUmbilicalProtocol

Task.umbilical

Methods in org.apache.hadoop.mapred with parameters of type TaskUmbilicalProtocol

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)