@InterfaceAudience.LimitedPrivate(value="Coprocesssor") @InterfaceStability.Evolving public abstract class BaseRowProcessorEndpoint<S extends Message,T extends Message> extends RowProcessorProtos.RowProcessorService implements CoprocessorService, Coprocessor
Region.processRowsWithLocks(org.apache.hadoop.hbase.regionserver.RowProcessor<?, ?>)
and Coprocessor endpoints.RowProcessorProtos.RowProcessorService.BlockingInterface, RowProcessorProtos.RowProcessorService.Interface, RowProcessorProtos.RowProcessorService.Stub
Coprocessor.State
PRIORITY_HIGHEST, PRIORITY_LOWEST, PRIORITY_SYSTEM, PRIORITY_USER, VERSION
Constructor and Description |
---|
BaseRowProcessorEndpoint() |
Modifier and Type | Method and Description |
---|---|
Service |
getService() |
void |
process(RpcController controller,
RowProcessorProtos.ProcessRequest request,
<any> done)
Pass a processor to region to process multiple rows atomically.
|
void |
start(CoprocessorEnvironment env)
Stores a reference to the coprocessor environment provided by the
RegionCoprocessorHost from the region where this
coprocessor is loaded. |
void |
stop(CoprocessorEnvironment env) |
callMethod, getDescriptor, getDescriptorForType, getRequestPrototype, getResponsePrototype, newBlockingStub, newReflectiveBlockingService, newReflectiveService, newStub
public void process(RpcController controller, RowProcessorProtos.ProcessRequest request, <any> done)
TestRowProcessorEndpoint
for example.
The request contains information for constructing processor
(see constructRowProcessorFromRequest(org.apache.hadoop.hbase.protobuf.generated.RowProcessorProtos.ProcessRequest)
. The processor object defines
the read-modify-write procedure.process
in class RowProcessorProtos.RowProcessorService
public Service getService()
getService
in interface CoprocessorService
public void start(CoprocessorEnvironment env) throws java.io.IOException
RegionCoprocessorHost
from the region where this
coprocessor is loaded. Since this is a coprocessor endpoint, it always expects to be loaded
on a table region, so always expects this to be an instance of
RegionCoprocessorEnvironment
.start
in interface Coprocessor
env
- the environment provided by the coprocessor hostjava.io.IOException
- if the provided environment is not an instance of
RegionCoprocessorEnvironment
public void stop(CoprocessorEnvironment env) throws java.io.IOException
stop
in interface Coprocessor
java.io.IOException