Package org.apache.hadoop.mapreduce.v2.api.impl.pb.client

Class MRClientProtocolPBClientImpl

java.lang.Object

org.apache.hadoop.mapreduce.v2.api.impl.pb.client.MRClientProtocolPBClientImpl

All Implemented Interfaces:

Closeable, AutoCloseable, MRClientProtocol

Direct Known Subclasses:

HSClientProtocolPBClientImpl

public class MRClientProtocolPBClientImpl
extends Object
implements MRClientProtocol, Closeable

Field Summary

Fields

Modifier and Type	Field	Description
protected MRClientProtocolPB	proxy

Constructor Summary

Constructors

Constructor	Description
MRClientProtocolPBClientImpl()
MRClientProtocolPBClientImpl(long clientVersion, InetSocketAddress addr, org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method	Description
CancelDelegationTokenResponse	cancelDelegationToken(CancelDelegationTokenRequest request)	Cancel an existing delegation token.
void	close()
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

Field Details

proxy

protected MRClientProtocolPB proxy

Constructor Details

MRClientProtocolPBClientImpl

public MRClientProtocolPBClientImpl()

MRClientProtocolPBClientImpl

public MRClientProtocolPBClientImpl(long clientVersion,
 InetSocketAddress addr,
 org.apache.hadoop.conf.Configuration conf)
                             throws IOException

Throws:

IOException

Method Details

getConnectAddress

public InetSocketAddress getConnectAddress()

Description copied from interface: MRClientProtocol

Address to which the client is connected

Specified by:

getConnectAddress in interface MRClientProtocol

Returns:

InetSocketAddress

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

getJobReport

public GetJobReportResponse getJobReport(GetJobReportRequest request)
                                  throws IOException

Specified by:

getJobReport in interface MRClientProtocol

Throws:

IOException

getTaskReport

public GetTaskReportResponse getTaskReport(GetTaskReportRequest request)
                                    throws IOException

Specified by:

getTaskReport in interface MRClientProtocol

Throws:

IOException

getTaskAttemptReport

public GetTaskAttemptReportResponse getTaskAttemptReport(GetTaskAttemptReportRequest request)
                                                  throws IOException

Specified by:

getTaskAttemptReport in interface MRClientProtocol

Throws:

IOException

getCounters

public GetCountersResponse getCounters(GetCountersRequest request)
                                throws IOException

Specified by:

getCounters in interface MRClientProtocol

Throws:

IOException

getTaskAttemptCompletionEvents

public GetTaskAttemptCompletionEventsResponse getTaskAttemptCompletionEvents(GetTaskAttemptCompletionEventsRequest request)
                                                                      throws IOException

Specified by:

getTaskAttemptCompletionEvents in interface MRClientProtocol

Throws:

IOException

getTaskReports

public GetTaskReportsResponse getTaskReports(GetTaskReportsRequest request)
                                      throws IOException

Specified by:

getTaskReports in interface MRClientProtocol

Throws:

IOException

getDiagnostics

public GetDiagnosticsResponse getDiagnostics(GetDiagnosticsRequest request)
                                      throws IOException

Specified by:

getDiagnostics in interface MRClientProtocol

Throws:

IOException

getDelegationToken

public GetDelegationTokenResponse getDelegationToken(GetDelegationTokenRequest request)
                                              throws IOException

Specified by:

getDelegationToken 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

failTaskAttempt

public FailTaskAttemptResponse failTaskAttempt(FailTaskAttemptRequest request)
                                        throws IOException

Specified by:

failTaskAttempt 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