org.apache.hadoop.mapred

Class ClientServiceDelegate

java.lang.Object

org.apache.hadoop.mapred.ClientServiceDelegate

public class ClientServiceDelegate
extends Object

Constructor Summary

Constructors

Constructor and Description
ClientServiceDelegate(Configuration conf, ResourceMgrDelegate rm, JobID jobId, MRClientProtocol historyServerProxy)

Method Summary

Methods

Modifier and Type	Method and Description
Counters	getJobCounters(JobID arg0)
JobStatus	getJobStatus(JobID oldJobID)
LogParams	getLogFilePath(JobID oldJobID, TaskAttemptID oldTaskAttemptID)
int	getMaxClientRetry()
TaskCompletionEvent[]	getTaskCompletionEvents(JobID arg0, int arg1, int arg2)
String[]	getTaskDiagnostics(TaskAttemptID arg0)
TaskReport[]	getTaskReports(JobID oldJobID, TaskType taskType)
boolean	killJob(JobID oldJobID)
boolean	killTask(TaskAttemptID taskAttemptID, boolean fail)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ClientServiceDelegate

public ClientServiceDelegate(Configuration conf,
                     ResourceMgrDelegate rm,
                     JobID jobId,
                     MRClientProtocol historyServerProxy)

Method Detail

getMaxClientRetry

public int getMaxClientRetry()

getJobCounters

public Counters getJobCounters(JobID arg0)
                        throws IOException,
                               InterruptedException

Throws:

IOException

InterruptedException

getTaskCompletionEvents

public TaskCompletionEvent[] getTaskCompletionEvents(JobID arg0,
                                            int arg1,
                                            int arg2)
                                              throws IOException,
                                                     InterruptedException

Throws:

IOException

InterruptedException

getTaskDiagnostics

public String[] getTaskDiagnostics(TaskAttemptID arg0)
                            throws IOException,
                                   InterruptedException

Throws:

IOException

InterruptedException

getJobStatus

public JobStatus getJobStatus(JobID oldJobID)
                       throws IOException

Throws:

IOException

getTaskReports

public TaskReport[] getTaskReports(JobID oldJobID,
                          TaskType taskType)
                            throws IOException

Throws:

IOException

killTask

public boolean killTask(TaskAttemptID taskAttemptID,
               boolean fail)
                 throws IOException

Throws:

IOException

killJob

public boolean killJob(JobID oldJobID)
                throws IOException

Throws:

IOException

getLogFilePath

public LogParams getLogFilePath(JobID oldJobID,
                       TaskAttemptID oldTaskAttemptID)
                         throws IOException

Throws:

IOException