org.apache.hadoop.yarn.proto

Interface MRClientProtocol.MRClientProtocolService.Interface

All Known Implementing Classes:

MRClientProtocol.MRClientProtocolService.Stub

Enclosing class:

MRClientProtocol.MRClientProtocolService

public static interface MRClientProtocol.MRClientProtocolService.Interface

Method Summary

Methods

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);
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);

Method Detail

getJobReport

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);

getTaskReport

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);

getTaskAttemptReport

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);

getCounters

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);

getTaskAttemptCompletionEvents

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);

getTaskReports

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);

getDiagnostics

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);

getDelegationToken

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);

killJob

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);

killTask

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);

killTaskAttempt

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);

failTaskAttempt

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);

renewDelegationToken

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);

cancelDelegationToken

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);