com.splicemachine.utils

Class BlockingProbeEndpoint

java.lang.Object

com.splicemachine.coprocessor.SpliceMessage.BlockingProbeEndpoint

com.splicemachine.utils.BlockingProbeEndpoint

All Implemented Interfaces:

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

public class BlockingProbeEndpoint
extends com.splicemachine.coprocessor.SpliceMessage.BlockingProbeEndpoint
implements org.apache.hadoop.hbase.coprocessor.SingletonCoprocessorService, org.apache.hadoop.hbase.Coprocessor

An HBase coprocessor used in testing to activate a BlockingProbe for a given administration stage on all regions.

Nested Class Summary

Nested classes/interfaces inherited from class com.splicemachine.coprocessor.SpliceMessage.BlockingProbeEndpoint

com.splicemachine.coprocessor.SpliceMessage.BlockingProbeEndpoint.BlockingInterface, com.splicemachine.coprocessor.SpliceMessage.BlockingProbeEndpoint.Interface, com.splicemachine.coprocessor.SpliceMessage.BlockingProbeEndpoint.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
BlockingProbeEndpoint()

Method Summary

Modifier and Type	Method and Description
void	blockPostCompact(com.google.protobuf.RpcController controller, com.splicemachine.coprocessor.SpliceMessage.BlockingProbeRequest request, com.google.protobuf.RpcCallback<com.splicemachine.coprocessor.SpliceMessage.BlockingProbeResponse> done) rpc blockPostCompact(.BlockingProbeRequest) returns (.BlockingProbeResponse);
void	blockPostFlush(com.google.protobuf.RpcController controller, com.splicemachine.coprocessor.SpliceMessage.BlockingProbeRequest request, com.google.protobuf.RpcCallback<com.splicemachine.coprocessor.SpliceMessage.BlockingProbeResponse> done) rpc blockPostFlush(.BlockingProbeRequest) returns (.BlockingProbeResponse);
void	blockPostSplit(com.google.protobuf.RpcController controller, com.splicemachine.coprocessor.SpliceMessage.BlockingProbeRequest request, com.google.protobuf.RpcCallback<com.splicemachine.coprocessor.SpliceMessage.BlockingProbeResponse> done) rpc blockPostSplit(.BlockingProbeRequest) returns (.BlockingProbeResponse);
void	blockPreCompact(com.google.protobuf.RpcController controller, com.splicemachine.coprocessor.SpliceMessage.BlockingProbeRequest request, com.google.protobuf.RpcCallback<com.splicemachine.coprocessor.SpliceMessage.BlockingProbeResponse> done) rpc blockPreCompact(.BlockingProbeRequest) returns (.BlockingProbeResponse);
void	blockPreFlush(com.google.protobuf.RpcController controller, com.splicemachine.coprocessor.SpliceMessage.BlockingProbeRequest request, com.google.protobuf.RpcCallback<com.splicemachine.coprocessor.SpliceMessage.BlockingProbeResponse> done) rpc blockPreFlush(.BlockingProbeRequest) returns (.BlockingProbeResponse);
void	blockPreSplit(com.google.protobuf.RpcController controller, com.splicemachine.coprocessor.SpliceMessage.BlockingProbeRequest request, com.google.protobuf.RpcCallback<com.splicemachine.coprocessor.SpliceMessage.BlockingProbeResponse> done) rpc blockPreSplit(.BlockingProbeRequest) returns (.BlockingProbeResponse);
com.google.protobuf.Service	getService()
void	start(org.apache.hadoop.hbase.CoprocessorEnvironment env)
void	stop(org.apache.hadoop.hbase.CoprocessorEnvironment env)

Methods inherited from class com.splicemachine.coprocessor.SpliceMessage.BlockingProbeEndpoint

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

BlockingProbeEndpoint

public BlockingProbeEndpoint()

Method Detail

start

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

Specified by:

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

Throws:

java.io.IOException

stop

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

Specified by:

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

Throws:

java.io.IOException

getService

public com.google.protobuf.Service getService()

Specified by:

getService in interface org.apache.hadoop.hbase.coprocessor.SingletonCoprocessorService

blockPreCompact

public void blockPreCompact(com.google.protobuf.RpcController controller,
                            com.splicemachine.coprocessor.SpliceMessage.BlockingProbeRequest request,
                            com.google.protobuf.RpcCallback<com.splicemachine.coprocessor.SpliceMessage.BlockingProbeResponse> done)

Description copied from class: com.splicemachine.coprocessor.SpliceMessage.BlockingProbeEndpoint

rpc blockPreCompact(.BlockingProbeRequest) returns (.BlockingProbeResponse);

Specified by:

blockPreCompact in class com.splicemachine.coprocessor.SpliceMessage.BlockingProbeEndpoint

blockPostCompact

public void blockPostCompact(com.google.protobuf.RpcController controller,
                             com.splicemachine.coprocessor.SpliceMessage.BlockingProbeRequest request,
                             com.google.protobuf.RpcCallback<com.splicemachine.coprocessor.SpliceMessage.BlockingProbeResponse> done)

Description copied from class: com.splicemachine.coprocessor.SpliceMessage.BlockingProbeEndpoint

rpc blockPostCompact(.BlockingProbeRequest) returns (.BlockingProbeResponse);

Specified by:

blockPostCompact in class com.splicemachine.coprocessor.SpliceMessage.BlockingProbeEndpoint

blockPreSplit

public void blockPreSplit(com.google.protobuf.RpcController controller,
                          com.splicemachine.coprocessor.SpliceMessage.BlockingProbeRequest request,
                          com.google.protobuf.RpcCallback<com.splicemachine.coprocessor.SpliceMessage.BlockingProbeResponse> done)

Description copied from class: com.splicemachine.coprocessor.SpliceMessage.BlockingProbeEndpoint

rpc blockPreSplit(.BlockingProbeRequest) returns (.BlockingProbeResponse);

Specified by:

blockPreSplit in class com.splicemachine.coprocessor.SpliceMessage.BlockingProbeEndpoint

blockPostSplit

public void blockPostSplit(com.google.protobuf.RpcController controller,
                           com.splicemachine.coprocessor.SpliceMessage.BlockingProbeRequest request,
                           com.google.protobuf.RpcCallback<com.splicemachine.coprocessor.SpliceMessage.BlockingProbeResponse> done)

Description copied from class: com.splicemachine.coprocessor.SpliceMessage.BlockingProbeEndpoint

rpc blockPostSplit(.BlockingProbeRequest) returns (.BlockingProbeResponse);

Specified by:

blockPostSplit in class com.splicemachine.coprocessor.SpliceMessage.BlockingProbeEndpoint

blockPreFlush

public void blockPreFlush(com.google.protobuf.RpcController controller,
                          com.splicemachine.coprocessor.SpliceMessage.BlockingProbeRequest request,
                          com.google.protobuf.RpcCallback<com.splicemachine.coprocessor.SpliceMessage.BlockingProbeResponse> done)

Description copied from class: com.splicemachine.coprocessor.SpliceMessage.BlockingProbeEndpoint

rpc blockPreFlush(.BlockingProbeRequest) returns (.BlockingProbeResponse);

Specified by:

blockPreFlush in class com.splicemachine.coprocessor.SpliceMessage.BlockingProbeEndpoint

blockPostFlush

public void blockPostFlush(com.google.protobuf.RpcController controller,
                           com.splicemachine.coprocessor.SpliceMessage.BlockingProbeRequest request,
                           com.google.protobuf.RpcCallback<com.splicemachine.coprocessor.SpliceMessage.BlockingProbeResponse> done)

Description copied from class: com.splicemachine.coprocessor.SpliceMessage.BlockingProbeEndpoint

rpc blockPostFlush(.BlockingProbeRequest) returns (.BlockingProbeResponse);

Specified by:

blockPostFlush in class com.splicemachine.coprocessor.SpliceMessage.BlockingProbeEndpoint