org.apache.hadoop.hbase.coprocessor

Class ProtobufCoprocessorService

java.lang.Object

org.apache.hadoop.hbase.ipc.protobuf.generated.TestRpcServiceProtos.TestProtobufRpcProto

org.apache.hadoop.hbase.coprocessor.ProtobufCoprocessorService

All Implemented Interfaces:

Coprocessor, CoprocessorService

public class ProtobufCoprocessorService
extends TestRpcServiceProtos.TestProtobufRpcProto
implements CoprocessorService, Coprocessor

Test implementation of a coprocessor endpoint exposing the TestRpcServiceProtos.TestProtobufRpcProto service methods. For internal use by unit tests only.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.ipc.protobuf.generated.TestRpcServiceProtos.TestProtobufRpcProto

TestRpcServiceProtos.TestProtobufRpcProto.BlockingInterface, TestRpcServiceProtos.TestProtobufRpcProto.Interface, TestRpcServiceProtos.TestProtobufRpcProto.Stub

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.Coprocessor

Coprocessor.State

Field Summary

Fields inherited from interface org.apache.hadoop.hbase.Coprocessor

PRIORITY_HIGHEST, PRIORITY_LOWEST, PRIORITY_SYSTEM, PRIORITY_USER, VERSION

Constructor Summary

Constructors

Constructor and Description
ProtobufCoprocessorService()

Method Summary

Modifier and Type	Method and Description
void	echo(RpcController controller, TestProtos.EchoRequestProto request, <any> done) rpc echo(.EchoRequestProto) returns (.EchoResponseProto);
void	error(RpcController controller, TestProtos.EmptyRequestProto request, <any> done) rpc error(.EmptyRequestProto) returns (.EmptyResponseProto);
Service	getService()
void	ping(RpcController controller, TestProtos.EmptyRequestProto request, <any> done) rpc ping(.EmptyRequestProto) returns (.EmptyResponseProto);
void	start(CoprocessorEnvironment env)
void	stop(CoprocessorEnvironment env)

Methods inherited from class org.apache.hadoop.hbase.ipc.protobuf.generated.TestRpcServiceProtos.TestProtobufRpcProto

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

Constructor Detail

ProtobufCoprocessorService

public ProtobufCoprocessorService()

Method Detail

getService

public Service getService()

Specified by:

getService in interface CoprocessorService

ping

public void ping(RpcController controller,
                 TestProtos.EmptyRequestProto request,
                 <any> done)

Description copied from class: TestRpcServiceProtos.TestProtobufRpcProto

rpc ping(.EmptyRequestProto) returns (.EmptyResponseProto);

Specified by:

ping in class TestRpcServiceProtos.TestProtobufRpcProto

echo

public void echo(RpcController controller,
                 TestProtos.EchoRequestProto request,
                 <any> done)

Description copied from class: TestRpcServiceProtos.TestProtobufRpcProto

rpc echo(.EchoRequestProto) returns (.EchoResponseProto);

Specified by:

echo in class TestRpcServiceProtos.TestProtobufRpcProto

error

public void error(RpcController controller,
                  TestProtos.EmptyRequestProto request,
                  <any> done)

Description copied from class: TestRpcServiceProtos.TestProtobufRpcProto

rpc error(.EmptyRequestProto) returns (.EmptyResponseProto);

Specified by:

error in class TestRpcServiceProtos.TestProtobufRpcProto

start

public void start(CoprocessorEnvironment env)
           throws IOException

Specified by:

start in interface Coprocessor

Throws:

IOException

stop

public void stop(CoprocessorEnvironment env)
          throws IOException

Specified by:

stop in interface Coprocessor

Throws:

IOException