org.apache.hadoop.yarn.proto

Class MRClientProtocol.MRClientProtocolService.Stub

java.lang.Object

org.apache.hadoop.yarn.proto.MRClientProtocol.MRClientProtocolService

org.apache.hadoop.yarn.proto.MRClientProtocol.MRClientProtocolService.Stub

All Implemented Interfaces:

com.google.protobuf.Service, MRClientProtocol.MRClientProtocolService.Interface

Enclosing class:

MRClientProtocol.MRClientProtocolService

public static final class MRClientProtocol.MRClientProtocolService.Stub
extends MRClientProtocol.MRClientProtocolService
implements MRClientProtocol.MRClientProtocolService.Interface

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.yarn.proto.MRClientProtocol.MRClientProtocolService

MRClientProtocol.MRClientProtocolService.BlockingInterface, MRClientProtocol.MRClientProtocolService.Interface, MRClientProtocol.MRClientProtocolService.Stub

Method Summary

Modifier and Type	Method and Description
void	cancelDelegationToken(com.google.protobuf.RpcController controller, org.apache.hadoop.security.proto.SecurityProtos.CancelDelegationTokenRequestProto request, com.google.protobuf.RpcCallback<org.apache.hadoop.security.proto.SecurityProtos.CancelDelegationTokenResponseProto> done) rpc cancelDelegationToken(.hadoop.common.CancelDelegationTokenRequestProto) returns (.hadoop.common.CancelDelegationTokenResponseProto);
void	failTaskAttempt(com.google.protobuf.RpcController controller, MRServiceProtos.FailTaskAttemptRequestProto request, com.google.protobuf.RpcCallback<MRServiceProtos.FailTaskAttemptResponseProto> done) rpc failTaskAttempt(.hadoop.mapreduce.FailTaskAttemptRequestProto) returns (.hadoop.mapreduce.FailTaskAttemptResponseProto);
com.google.protobuf.RpcChannel	getChannel()
void	getCounters(com.google.protobuf.RpcController controller, MRServiceProtos.GetCountersRequestProto request, com.google.protobuf.RpcCallback<MRServiceProtos.GetCountersResponseProto> done) rpc getCounters(.hadoop.mapreduce.GetCountersRequestProto) returns (.hadoop.mapreduce.GetCountersResponseProto);
void	getDelegationToken(com.google.protobuf.RpcController controller, org.apache.hadoop.security.proto.SecurityProtos.GetDelegationTokenRequestProto request, com.google.protobuf.RpcCallback<org.apache.hadoop.security.proto.SecurityProtos.GetDelegationTokenResponseProto> done) rpc getDelegationToken(.hadoop.common.GetDelegationTokenRequestProto) returns (.hadoop.common.GetDelegationTokenResponseProto);
void	getDiagnostics(com.google.protobuf.RpcController controller, MRServiceProtos.GetDiagnosticsRequestProto request, com.google.protobuf.RpcCallback<MRServiceProtos.GetDiagnosticsResponseProto> done) rpc getDiagnostics(.hadoop.mapreduce.GetDiagnosticsRequestProto) returns (.hadoop.mapreduce.GetDiagnosticsResponseProto);
void	getJobReport(com.google.protobuf.RpcController controller, MRServiceProtos.GetJobReportRequestProto request, com.google.protobuf.RpcCallback<MRServiceProtos.GetJobReportResponseProto> done) rpc getJobReport(.hadoop.mapreduce.GetJobReportRequestProto) returns (.hadoop.mapreduce.GetJobReportResponseProto);
void	getTaskAttemptCompletionEvents(com.google.protobuf.RpcController controller, MRServiceProtos.GetTaskAttemptCompletionEventsRequestProto request, com.google.protobuf.RpcCallback<MRServiceProtos.GetTaskAttemptCompletionEventsResponseProto> done) rpc getTaskAttemptCompletionEvents(.hadoop.mapreduce.GetTaskAttemptCompletionEventsRequestProto) returns (.hadoop.mapreduce.GetTaskAttemptCompletionEventsResponseProto);
void	getTaskAttemptReport(com.google.protobuf.RpcController controller, MRServiceProtos.GetTaskAttemptReportRequestProto request, com.google.protobuf.RpcCallback<MRServiceProtos.GetTaskAttemptReportResponseProto> done) rpc getTaskAttemptReport(.hadoop.mapreduce.GetTaskAttemptReportRequestProto) returns (.hadoop.mapreduce.GetTaskAttemptReportResponseProto);
void	getTaskReport(com.google.protobuf.RpcController controller, MRServiceProtos.GetTaskReportRequestProto request, com.google.protobuf.RpcCallback<MRServiceProtos.GetTaskReportResponseProto> done) rpc getTaskReport(.hadoop.mapreduce.GetTaskReportRequestProto) returns (.hadoop.mapreduce.GetTaskReportResponseProto);
void	getTaskReports(com.google.protobuf.RpcController controller, MRServiceProtos.GetTaskReportsRequestProto request, com.google.protobuf.RpcCallback<MRServiceProtos.GetTaskReportsResponseProto> done) rpc getTaskReports(.hadoop.mapreduce.GetTaskReportsRequestProto) returns (.hadoop.mapreduce.GetTaskReportsResponseProto);
void	killJob(com.google.protobuf.RpcController controller, MRServiceProtos.KillJobRequestProto request, com.google.protobuf.RpcCallback<MRServiceProtos.KillJobResponseProto> done) rpc killJob(.hadoop.mapreduce.KillJobRequestProto) returns (.hadoop.mapreduce.KillJobResponseProto);
void	killTask(com.google.protobuf.RpcController controller, MRServiceProtos.KillTaskRequestProto request, com.google.protobuf.RpcCallback<MRServiceProtos.KillTaskResponseProto> done) rpc killTask(.hadoop.mapreduce.KillTaskRequestProto) returns (.hadoop.mapreduce.KillTaskResponseProto);
void	killTaskAttempt(com.google.protobuf.RpcController controller, MRServiceProtos.KillTaskAttemptRequestProto request, com.google.protobuf.RpcCallback<MRServiceProtos.KillTaskAttemptResponseProto> done) rpc killTaskAttempt(.hadoop.mapreduce.KillTaskAttemptRequestProto) returns (.hadoop.mapreduce.KillTaskAttemptResponseProto);
void	renewDelegationToken(com.google.protobuf.RpcController controller, org.apache.hadoop.security.proto.SecurityProtos.RenewDelegationTokenRequestProto request, com.google.protobuf.RpcCallback<org.apache.hadoop.security.proto.SecurityProtos.RenewDelegationTokenResponseProto> done) rpc renewDelegationToken(.hadoop.common.RenewDelegationTokenRequestProto) returns (.hadoop.common.RenewDelegationTokenResponseProto);

Methods inherited from class org.apache.hadoop.yarn.proto.MRClientProtocol.MRClientProtocolService

callMethod, getDescriptor, getDescriptorForType, getRequestPrototype, getResponsePrototype, newBlockingStub, newReflectiveBlockingService, newReflectiveService, newStub

Methods inherited from class java.lang.Object

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

Method Detail

getChannel

public com.google.protobuf.RpcChannel getChannel()

getJobReport

public void getJobReport(com.google.protobuf.RpcController controller,
                         MRServiceProtos.GetJobReportRequestProto request,
                         com.google.protobuf.RpcCallback<MRServiceProtos.GetJobReportResponseProto> done)

Description copied from class: MRClientProtocol.MRClientProtocolService

rpc getJobReport(.hadoop.mapreduce.GetJobReportRequestProto) returns (.hadoop.mapreduce.GetJobReportResponseProto);

Specified by:

getJobReport in interface MRClientProtocol.MRClientProtocolService.Interface

Specified by:

getJobReport in class MRClientProtocol.MRClientProtocolService

getTaskReport

public void getTaskReport(com.google.protobuf.RpcController controller,
                          MRServiceProtos.GetTaskReportRequestProto request,
                          com.google.protobuf.RpcCallback<MRServiceProtos.GetTaskReportResponseProto> done)

Description copied from class: MRClientProtocol.MRClientProtocolService

rpc getTaskReport(.hadoop.mapreduce.GetTaskReportRequestProto) returns (.hadoop.mapreduce.GetTaskReportResponseProto);

Specified by:

getTaskReport in interface MRClientProtocol.MRClientProtocolService.Interface

Specified by:

getTaskReport in class MRClientProtocol.MRClientProtocolService

getTaskAttemptReport

public void getTaskAttemptReport(com.google.protobuf.RpcController controller,
                                 MRServiceProtos.GetTaskAttemptReportRequestProto request,
                                 com.google.protobuf.RpcCallback<MRServiceProtos.GetTaskAttemptReportResponseProto> done)

Description copied from class: MRClientProtocol.MRClientProtocolService

rpc getTaskAttemptReport(.hadoop.mapreduce.GetTaskAttemptReportRequestProto) returns (.hadoop.mapreduce.GetTaskAttemptReportResponseProto);

Specified by:

getTaskAttemptReport in interface MRClientProtocol.MRClientProtocolService.Interface

Specified by:

getTaskAttemptReport in class MRClientProtocol.MRClientProtocolService

getCounters

public void getCounters(com.google.protobuf.RpcController controller,
                        MRServiceProtos.GetCountersRequestProto request,
                        com.google.protobuf.RpcCallback<MRServiceProtos.GetCountersResponseProto> done)

Description copied from class: MRClientProtocol.MRClientProtocolService

rpc getCounters(.hadoop.mapreduce.GetCountersRequestProto) returns (.hadoop.mapreduce.GetCountersResponseProto);

Specified by:

getCounters in interface MRClientProtocol.MRClientProtocolService.Interface

Specified by:

getCounters in class MRClientProtocol.MRClientProtocolService

getTaskAttemptCompletionEvents

public void getTaskAttemptCompletionEvents(com.google.protobuf.RpcController controller,
                                           MRServiceProtos.GetTaskAttemptCompletionEventsRequestProto request,
                                           com.google.protobuf.RpcCallback<MRServiceProtos.GetTaskAttemptCompletionEventsResponseProto> done)

Description copied from class: MRClientProtocol.MRClientProtocolService

rpc getTaskAttemptCompletionEvents(.hadoop.mapreduce.GetTaskAttemptCompletionEventsRequestProto) returns (.hadoop.mapreduce.GetTaskAttemptCompletionEventsResponseProto);

Specified by:

getTaskAttemptCompletionEvents in interface MRClientProtocol.MRClientProtocolService.Interface

Specified by:

getTaskAttemptCompletionEvents in class MRClientProtocol.MRClientProtocolService

getTaskReports

public void getTaskReports(com.google.protobuf.RpcController controller,
                           MRServiceProtos.GetTaskReportsRequestProto request,
                           com.google.protobuf.RpcCallback<MRServiceProtos.GetTaskReportsResponseProto> done)

Description copied from class: MRClientProtocol.MRClientProtocolService

rpc getTaskReports(.hadoop.mapreduce.GetTaskReportsRequestProto) returns (.hadoop.mapreduce.GetTaskReportsResponseProto);

Specified by:

getTaskReports in interface MRClientProtocol.MRClientProtocolService.Interface

Specified by:

getTaskReports in class MRClientProtocol.MRClientProtocolService

getDiagnostics

public void getDiagnostics(com.google.protobuf.RpcController controller,
                           MRServiceProtos.GetDiagnosticsRequestProto request,
                           com.google.protobuf.RpcCallback<MRServiceProtos.GetDiagnosticsResponseProto> done)

Description copied from class: MRClientProtocol.MRClientProtocolService

rpc getDiagnostics(.hadoop.mapreduce.GetDiagnosticsRequestProto) returns (.hadoop.mapreduce.GetDiagnosticsResponseProto);

Specified by:

getDiagnostics in interface MRClientProtocol.MRClientProtocolService.Interface

Specified by:

getDiagnostics in class MRClientProtocol.MRClientProtocolService

getDelegationToken

public void getDelegationToken(com.google.protobuf.RpcController controller,
                               org.apache.hadoop.security.proto.SecurityProtos.GetDelegationTokenRequestProto request,
                               com.google.protobuf.RpcCallback<org.apache.hadoop.security.proto.SecurityProtos.GetDelegationTokenResponseProto> done)

Description copied from class: MRClientProtocol.MRClientProtocolService

rpc getDelegationToken(.hadoop.common.GetDelegationTokenRequestProto) returns (.hadoop.common.GetDelegationTokenResponseProto);

Specified by:

getDelegationToken in interface MRClientProtocol.MRClientProtocolService.Interface

Specified by:

getDelegationToken in class MRClientProtocol.MRClientProtocolService

killJob

public void killJob(com.google.protobuf.RpcController controller,
                    MRServiceProtos.KillJobRequestProto request,
                    com.google.protobuf.RpcCallback<MRServiceProtos.KillJobResponseProto> done)

Description copied from class: MRClientProtocol.MRClientProtocolService

rpc killJob(.hadoop.mapreduce.KillJobRequestProto) returns (.hadoop.mapreduce.KillJobResponseProto);

Specified by:

killJob in interface MRClientProtocol.MRClientProtocolService.Interface

Specified by:

killJob in class MRClientProtocol.MRClientProtocolService

killTask

public void killTask(com.google.protobuf.RpcController controller,
                     MRServiceProtos.KillTaskRequestProto request,
                     com.google.protobuf.RpcCallback<MRServiceProtos.KillTaskResponseProto> done)

Description copied from class: MRClientProtocol.MRClientProtocolService

rpc killTask(.hadoop.mapreduce.KillTaskRequestProto) returns (.hadoop.mapreduce.KillTaskResponseProto);

Specified by:

killTask in interface MRClientProtocol.MRClientProtocolService.Interface

Specified by:

killTask in class MRClientProtocol.MRClientProtocolService

killTaskAttempt

public void killTaskAttempt(com.google.protobuf.RpcController controller,
                            MRServiceProtos.KillTaskAttemptRequestProto request,
                            com.google.protobuf.RpcCallback<MRServiceProtos.KillTaskAttemptResponseProto> done)

Description copied from class: MRClientProtocol.MRClientProtocolService

rpc killTaskAttempt(.hadoop.mapreduce.KillTaskAttemptRequestProto) returns (.hadoop.mapreduce.KillTaskAttemptResponseProto);

Specified by:

killTaskAttempt in interface MRClientProtocol.MRClientProtocolService.Interface

Specified by:

killTaskAttempt in class MRClientProtocol.MRClientProtocolService

failTaskAttempt

public void failTaskAttempt(com.google.protobuf.RpcController controller,
                            MRServiceProtos.FailTaskAttemptRequestProto request,
                            com.google.protobuf.RpcCallback<MRServiceProtos.FailTaskAttemptResponseProto> done)

Description copied from class: MRClientProtocol.MRClientProtocolService

rpc failTaskAttempt(.hadoop.mapreduce.FailTaskAttemptRequestProto) returns (.hadoop.mapreduce.FailTaskAttemptResponseProto);

Specified by:

failTaskAttempt in interface MRClientProtocol.MRClientProtocolService.Interface

Specified by:

failTaskAttempt in class MRClientProtocol.MRClientProtocolService

renewDelegationToken

public void renewDelegationToken(com.google.protobuf.RpcController controller,
                                 org.apache.hadoop.security.proto.SecurityProtos.RenewDelegationTokenRequestProto request,
                                 com.google.protobuf.RpcCallback<org.apache.hadoop.security.proto.SecurityProtos.RenewDelegationTokenResponseProto> done)

Description copied from class: MRClientProtocol.MRClientProtocolService

rpc renewDelegationToken(.hadoop.common.RenewDelegationTokenRequestProto) returns (.hadoop.common.RenewDelegationTokenResponseProto);

Specified by:

renewDelegationToken in interface MRClientProtocol.MRClientProtocolService.Interface

Specified by:

renewDelegationToken in class MRClientProtocol.MRClientProtocolService

cancelDelegationToken

public void cancelDelegationToken(com.google.protobuf.RpcController controller,
                                  org.apache.hadoop.security.proto.SecurityProtos.CancelDelegationTokenRequestProto request,
                                  com.google.protobuf.RpcCallback<org.apache.hadoop.security.proto.SecurityProtos.CancelDelegationTokenResponseProto> done)

Description copied from class: MRClientProtocol.MRClientProtocolService

rpc cancelDelegationToken(.hadoop.common.CancelDelegationTokenRequestProto) returns (.hadoop.common.CancelDelegationTokenResponseProto);

Specified by:

cancelDelegationToken in interface MRClientProtocol.MRClientProtocolService.Interface

Specified by:

cancelDelegationToken in class MRClientProtocol.MRClientProtocolService