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(org.apache.hadoop.conf.Configuration conf, ResourceMgrDelegate rm, org.apache.hadoop.mapreduce.JobID jobId, org.apache.hadoop.mapreduce.v2.api.MRClientProtocol historyServerProxy)

Method Summary

Modifier and Type	Method and Description
void	close()
org.apache.hadoop.mapreduce.Counters	getJobCounters(org.apache.hadoop.mapreduce.JobID arg0)
org.apache.hadoop.mapreduce.JobStatus	getJobStatus(org.apache.hadoop.mapreduce.JobID oldJobID)
org.apache.hadoop.mapreduce.v2.LogParams	getLogFilePath(org.apache.hadoop.mapreduce.JobID oldJobID, org.apache.hadoop.mapreduce.TaskAttemptID oldTaskAttemptID)
int	getMaxClientRetry()
org.apache.hadoop.mapred.TaskCompletionEvent[]	getTaskCompletionEvents(org.apache.hadoop.mapreduce.JobID arg0, int arg1, int arg2)
String[]	getTaskDiagnostics(org.apache.hadoop.mapreduce.TaskAttemptID arg0)
org.apache.hadoop.mapreduce.TaskReport[]	getTaskReports(org.apache.hadoop.mapreduce.JobID oldJobID, org.apache.hadoop.mapreduce.TaskType taskType)
boolean	killJob(org.apache.hadoop.mapreduce.JobID oldJobID)
boolean	killTask(org.apache.hadoop.mapreduce.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(org.apache.hadoop.conf.Configuration conf,
                             ResourceMgrDelegate rm,
                             org.apache.hadoop.mapreduce.JobID jobId,
                             org.apache.hadoop.mapreduce.v2.api.MRClientProtocol historyServerProxy)

Method Detail

getMaxClientRetry

@VisibleForTesting
public int getMaxClientRetry()

getJobCounters

public org.apache.hadoop.mapreduce.Counters getJobCounters(org.apache.hadoop.mapreduce.JobID arg0)
                                                    throws IOException,
                                                           InterruptedException

Throws:

IOException

InterruptedException

getTaskCompletionEvents

public org.apache.hadoop.mapred.TaskCompletionEvent[] getTaskCompletionEvents(org.apache.hadoop.mapreduce.JobID arg0,
                                                                              int arg1,
                                                                              int arg2)
                                                                       throws IOException,
                                                                              InterruptedException

Throws:

IOException

InterruptedException

getTaskDiagnostics

public String[] getTaskDiagnostics(org.apache.hadoop.mapreduce.TaskAttemptID arg0)
                            throws IOException,
                                   InterruptedException

Throws:

IOException

InterruptedException

getJobStatus

public org.apache.hadoop.mapreduce.JobStatus getJobStatus(org.apache.hadoop.mapreduce.JobID oldJobID)
                                                   throws IOException

Throws:

IOException

getTaskReports

public org.apache.hadoop.mapreduce.TaskReport[] getTaskReports(org.apache.hadoop.mapreduce.JobID oldJobID,
                                                               org.apache.hadoop.mapreduce.TaskType taskType)
                                                        throws IOException

Throws:

IOException

killTask

public boolean killTask(org.apache.hadoop.mapreduce.TaskAttemptID taskAttemptID,
                        boolean fail)
                 throws IOException

Throws:

IOException

killJob

public boolean killJob(org.apache.hadoop.mapreduce.JobID oldJobID)
                throws IOException

Throws:

IOException

getLogFilePath

public org.apache.hadoop.mapreduce.v2.LogParams getLogFilePath(org.apache.hadoop.mapreduce.JobID oldJobID,
                                                               org.apache.hadoop.mapreduce.TaskAttemptID oldTaskAttemptID)
                                                        throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Throws:

IOException