public class MRClientProtocolPBServiceImpl extends Object implements MRClientProtocolPB
Constructor and Description |
---|
MRClientProtocolPBServiceImpl(MRClientProtocol impl) |
public MRClientProtocolPBServiceImpl(MRClientProtocol impl)
public MRServiceProtos.GetJobReportResponseProto getJobReport(com.google.protobuf.RpcController controller, MRServiceProtos.GetJobReportRequestProto proto) throws com.google.protobuf.ServiceException
getJobReport
in interface MRClientProtocol.MRClientProtocolService.BlockingInterface
com.google.protobuf.ServiceException
public MRServiceProtos.GetTaskReportResponseProto getTaskReport(com.google.protobuf.RpcController controller, MRServiceProtos.GetTaskReportRequestProto proto) throws com.google.protobuf.ServiceException
getTaskReport
in interface MRClientProtocol.MRClientProtocolService.BlockingInterface
com.google.protobuf.ServiceException
public MRServiceProtos.GetTaskAttemptReportResponseProto getTaskAttemptReport(com.google.protobuf.RpcController controller, MRServiceProtos.GetTaskAttemptReportRequestProto proto) throws com.google.protobuf.ServiceException
getTaskAttemptReport
in interface MRClientProtocol.MRClientProtocolService.BlockingInterface
com.google.protobuf.ServiceException
public MRServiceProtos.GetCountersResponseProto getCounters(com.google.protobuf.RpcController controller, MRServiceProtos.GetCountersRequestProto proto) throws com.google.protobuf.ServiceException
getCounters
in interface MRClientProtocol.MRClientProtocolService.BlockingInterface
com.google.protobuf.ServiceException
public MRServiceProtos.GetTaskAttemptCompletionEventsResponseProto getTaskAttemptCompletionEvents(com.google.protobuf.RpcController controller, MRServiceProtos.GetTaskAttemptCompletionEventsRequestProto proto) throws com.google.protobuf.ServiceException
getTaskAttemptCompletionEvents
in interface MRClientProtocol.MRClientProtocolService.BlockingInterface
com.google.protobuf.ServiceException
public MRServiceProtos.GetTaskReportsResponseProto getTaskReports(com.google.protobuf.RpcController controller, MRServiceProtos.GetTaskReportsRequestProto proto) throws com.google.protobuf.ServiceException
getTaskReports
in interface MRClientProtocol.MRClientProtocolService.BlockingInterface
com.google.protobuf.ServiceException
public MRServiceProtos.GetDiagnosticsResponseProto getDiagnostics(com.google.protobuf.RpcController controller, MRServiceProtos.GetDiagnosticsRequestProto proto) throws com.google.protobuf.ServiceException
getDiagnostics
in interface MRClientProtocol.MRClientProtocolService.BlockingInterface
com.google.protobuf.ServiceException
public SecurityProtos.GetDelegationTokenResponseProto getDelegationToken(com.google.protobuf.RpcController controller, SecurityProtos.GetDelegationTokenRequestProto proto) throws com.google.protobuf.ServiceException
getDelegationToken
in interface MRClientProtocol.MRClientProtocolService.BlockingInterface
com.google.protobuf.ServiceException
public MRServiceProtos.KillJobResponseProto killJob(com.google.protobuf.RpcController controller, MRServiceProtos.KillJobRequestProto proto) throws com.google.protobuf.ServiceException
killJob
in interface MRClientProtocol.MRClientProtocolService.BlockingInterface
com.google.protobuf.ServiceException
public MRServiceProtos.KillTaskResponseProto killTask(com.google.protobuf.RpcController controller, MRServiceProtos.KillTaskRequestProto proto) throws com.google.protobuf.ServiceException
killTask
in interface MRClientProtocol.MRClientProtocolService.BlockingInterface
com.google.protobuf.ServiceException
public MRServiceProtos.KillTaskAttemptResponseProto killTaskAttempt(com.google.protobuf.RpcController controller, MRServiceProtos.KillTaskAttemptRequestProto proto) throws com.google.protobuf.ServiceException
killTaskAttempt
in interface MRClientProtocol.MRClientProtocolService.BlockingInterface
com.google.protobuf.ServiceException
public MRServiceProtos.FailTaskAttemptResponseProto failTaskAttempt(com.google.protobuf.RpcController controller, MRServiceProtos.FailTaskAttemptRequestProto proto) throws com.google.protobuf.ServiceException
failTaskAttempt
in interface MRClientProtocol.MRClientProtocolService.BlockingInterface
com.google.protobuf.ServiceException
public SecurityProtos.RenewDelegationTokenResponseProto renewDelegationToken(com.google.protobuf.RpcController controller, SecurityProtos.RenewDelegationTokenRequestProto proto) throws com.google.protobuf.ServiceException
renewDelegationToken
in interface MRClientProtocol.MRClientProtocolService.BlockingInterface
com.google.protobuf.ServiceException
public SecurityProtos.CancelDelegationTokenResponseProto cancelDelegationToken(com.google.protobuf.RpcController controller, SecurityProtos.CancelDelegationTokenRequestProto proto) throws com.google.protobuf.ServiceException
cancelDelegationToken
in interface MRClientProtocol.MRClientProtocolService.BlockingInterface
com.google.protobuf.ServiceException
Copyright © 2013 Apache Software Foundation. All rights reserved.