org.apache.hadoop.mapred

Class NotRunningJob

java.lang.Object

org.apache.hadoop.mapred.NotRunningJob

All Implemented Interfaces:

MRClientProtocol

public class NotRunningJob
extends Object
implements MRClientProtocol

Method Summary

Methods

Modifier and Type	Method and Description
CancelDelegationTokenResponse	cancelDelegationToken(CancelDelegationTokenRequest request) Cancel an existing delegation token.
FailTaskAttemptResponse	failTaskAttempt(FailTaskAttemptRequest request)
InetSocketAddress	getConnectAddress() Address to which the client is connected
GetCountersResponse	getCounters(GetCountersRequest request)
GetDelegationTokenResponse	getDelegationToken(GetDelegationTokenRequest request)
GetDiagnosticsResponse	getDiagnostics(GetDiagnosticsRequest request)
GetJobReportResponse	getJobReport(GetJobReportRequest request)
GetTaskAttemptCompletionEventsResponse	getTaskAttemptCompletionEvents(GetTaskAttemptCompletionEventsRequest request)
GetTaskAttemptReportResponse	getTaskAttemptReport(GetTaskAttemptReportRequest request)
GetTaskReportResponse	getTaskReport(GetTaskReportRequest request)
GetTaskReportsResponse	getTaskReports(GetTaskReportsRequest request)
KillJobResponse	killJob(KillJobRequest request)
KillTaskResponse	killTask(KillTaskRequest request)
KillTaskAttemptResponse	killTaskAttempt(KillTaskAttemptRequest request)
RenewDelegationTokenResponse	renewDelegationToken(RenewDelegationTokenRequest request) Renew an existing delegation token.

Methods inherited from class java.lang.Object

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

Method Detail

failTaskAttempt

public FailTaskAttemptResponse failTaskAttempt(FailTaskAttemptRequest request)
                                        throws IOException

Specified by:

failTaskAttempt in interface MRClientProtocol

Throws:

IOException

getCounters

public GetCountersResponse getCounters(GetCountersRequest request)
                                throws IOException

Specified by:

getCounters in interface MRClientProtocol

Throws:

IOException

getDiagnostics

public GetDiagnosticsResponse getDiagnostics(GetDiagnosticsRequest request)
                                      throws IOException

Specified by:

getDiagnostics in interface MRClientProtocol

Throws:

IOException

getJobReport

public GetJobReportResponse getJobReport(GetJobReportRequest request)
                                  throws IOException

Specified by:

getJobReport in interface MRClientProtocol

Throws:

IOException

getTaskAttemptCompletionEvents

public GetTaskAttemptCompletionEventsResponse getTaskAttemptCompletionEvents(GetTaskAttemptCompletionEventsRequest request)
                                                                      throws IOException

Specified by:

getTaskAttemptCompletionEvents in interface MRClientProtocol

Throws:

IOException

getTaskAttemptReport

public GetTaskAttemptReportResponse getTaskAttemptReport(GetTaskAttemptReportRequest request)
                                                  throws IOException

Specified by:

getTaskAttemptReport in interface MRClientProtocol

Throws:

IOException

getTaskReport

public GetTaskReportResponse getTaskReport(GetTaskReportRequest request)
                                    throws IOException

Specified by:

getTaskReport in interface MRClientProtocol

Throws:

IOException

getTaskReports

public GetTaskReportsResponse getTaskReports(GetTaskReportsRequest request)
                                      throws IOException

Specified by:

getTaskReports in interface MRClientProtocol

Throws:

IOException

killJob

public KillJobResponse killJob(KillJobRequest request)
                        throws IOException

Specified by:

killJob in interface MRClientProtocol

Throws:

IOException

killTask

public KillTaskResponse killTask(KillTaskRequest request)
                          throws IOException

Specified by:

killTask in interface MRClientProtocol

Throws:

IOException

killTaskAttempt

public KillTaskAttemptResponse killTaskAttempt(KillTaskAttemptRequest request)
                                        throws IOException

Specified by:

killTaskAttempt in interface MRClientProtocol

Throws:

IOException

getDelegationToken

public GetDelegationTokenResponse getDelegationToken(GetDelegationTokenRequest request)
                                              throws IOException

Specified by:

getDelegationToken in interface MRClientProtocol

Throws:

IOException

renewDelegationToken

public RenewDelegationTokenResponse renewDelegationToken(RenewDelegationTokenRequest request)
                                                  throws IOException

Description copied from interface: MRClientProtocol

Renew an existing delegation token.

Specified by:

renewDelegationToken in interface MRClientProtocol

Parameters:

request - the delegation token to be renewed.

Returns:

the new expiry time for the delegation token.

Throws:

IOException

cancelDelegationToken

public CancelDelegationTokenResponse cancelDelegationToken(CancelDelegationTokenRequest request)
                                                    throws IOException

Description copied from interface: MRClientProtocol

Cancel an existing delegation token.

Specified by:

cancelDelegationToken in interface MRClientProtocol

Parameters:

request - the delegation token to be cancelled.

Returns:

an empty response.

Throws:

IOException

getConnectAddress

public InetSocketAddress getConnectAddress()

Description copied from interface: MRClientProtocol

Address to which the client is connected

Specified by:

getConnectAddress in interface MRClientProtocol

Returns:

InetSocketAddress