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:

com.google.protobuf.Service, org.apache.hadoop.hbase.Coprocessor, org.apache.hadoop.hbase.coprocessor.MasterCoprocessor, org.apache.hadoop.hbase.coprocessor.RegionCoprocessor

public class ProtobufCoprocessorService
extends org.apache.hadoop.hbase.ipc.protobuf.generated.TestRpcServiceProtos.TestProtobufRpcProto
implements org.apache.hadoop.hbase.coprocessor.MasterCoprocessor, org.apache.hadoop.hbase.coprocessor.RegionCoprocessor

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

org.apache.hadoop.hbase.ipc.protobuf.generated.TestRpcServiceProtos.TestProtobufRpcProto.BlockingInterface, org.apache.hadoop.hbase.ipc.protobuf.generated.TestRpcServiceProtos.TestProtobufRpcProto.Interface, org.apache.hadoop.hbase.ipc.protobuf.generated.TestRpcServiceProtos.TestProtobufRpcProto.Stub

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

org.apache.hadoop.hbase.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	addr(com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.ipc.protobuf.generated.TestProtos.EmptyRequestProto request, com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.ipc.protobuf.generated.TestProtos.AddrResponseProto> done)
void	echo(com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.ipc.protobuf.generated.TestProtos.EchoRequestProto request, com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.ipc.protobuf.generated.TestProtos.EchoResponseProto> done)
void	error(com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.ipc.protobuf.generated.TestProtos.EmptyRequestProto request, com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.ipc.protobuf.generated.TestProtos.EmptyResponseProto> done)
Iterable<com.google.protobuf.Service>	getServices()
void	pause(com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.ipc.protobuf.generated.TestProtos.PauseRequestProto request, com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.ipc.protobuf.generated.TestProtos.EmptyResponseProto> done)
void	ping(com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.ipc.protobuf.generated.TestProtos.EmptyRequestProto request, com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.ipc.protobuf.generated.TestProtos.EmptyResponseProto> done)
void	start(org.apache.hadoop.hbase.CoprocessorEnvironment env)
void	stop(org.apache.hadoop.hbase.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

Methods inherited from interface org.apache.hadoop.hbase.coprocessor.MasterCoprocessor

getMasterObserver

Methods inherited from interface org.apache.hadoop.hbase.coprocessor.RegionCoprocessor

getBulkLoadObserver, getEndpointObserver, getRegionObserver

Constructor Detail

ProtobufCoprocessorService

public ProtobufCoprocessorService()

Method Detail

getServices

public Iterable<com.google.protobuf.Service> getServices()

Specified by:

getServices in interface org.apache.hadoop.hbase.Coprocessor

ping

public void ping(com.google.protobuf.RpcController controller,
                 org.apache.hadoop.hbase.ipc.protobuf.generated.TestProtos.EmptyRequestProto request,
                 com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.ipc.protobuf.generated.TestProtos.EmptyResponseProto> done)

Specified by:

ping in class org.apache.hadoop.hbase.ipc.protobuf.generated.TestRpcServiceProtos.TestProtobufRpcProto

echo

public void echo(com.google.protobuf.RpcController controller,
                 org.apache.hadoop.hbase.ipc.protobuf.generated.TestProtos.EchoRequestProto request,
                 com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.ipc.protobuf.generated.TestProtos.EchoResponseProto> done)

Specified by:

echo in class org.apache.hadoop.hbase.ipc.protobuf.generated.TestRpcServiceProtos.TestProtobufRpcProto

error

public void error(com.google.protobuf.RpcController controller,
                  org.apache.hadoop.hbase.ipc.protobuf.generated.TestProtos.EmptyRequestProto request,
                  com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.ipc.protobuf.generated.TestProtos.EmptyResponseProto> done)

Specified by:

error in class org.apache.hadoop.hbase.ipc.protobuf.generated.TestRpcServiceProtos.TestProtobufRpcProto

pause

public void pause(com.google.protobuf.RpcController controller,
                  org.apache.hadoop.hbase.ipc.protobuf.generated.TestProtos.PauseRequestProto request,
                  com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.ipc.protobuf.generated.TestProtos.EmptyResponseProto> done)

Specified by:

pause in class org.apache.hadoop.hbase.ipc.protobuf.generated.TestRpcServiceProtos.TestProtobufRpcProto

addr

public void addr(com.google.protobuf.RpcController controller,
                 org.apache.hadoop.hbase.ipc.protobuf.generated.TestProtos.EmptyRequestProto request,
                 com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.ipc.protobuf.generated.TestProtos.AddrResponseProto> done)

Specified by:

addr in class org.apache.hadoop.hbase.ipc.protobuf.generated.TestRpcServiceProtos.TestProtobufRpcProto

start

public void start(org.apache.hadoop.hbase.CoprocessorEnvironment env)
           throws IOException

Specified by:

start in interface org.apache.hadoop.hbase.Coprocessor

Throws:

IOException

stop

public void stop(org.apache.hadoop.hbase.CoprocessorEnvironment env)
          throws IOException

Specified by:

stop in interface org.apache.hadoop.hbase.Coprocessor

Throws:

IOException