org.apache.hadoop.hbase.coprocessor

Class TestRowProcessorEndpoint.RowProcessorEndpoint<S extends com.google.protobuf.Message,T extends com.google.protobuf.Message>

java.lang.Object

org.apache.hadoop.hbase.protobuf.generated.RowProcessorProtos.RowProcessorService

org.apache.hadoop.hbase.coprocessor.BaseRowProcessorEndpoint<S,T>

org.apache.hadoop.hbase.coprocessor.TestRowProcessorEndpoint.RowProcessorEndpoint<S,T>

All Implemented Interfaces:

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

Enclosing class:

TestRowProcessorEndpoint

public static class TestRowProcessorEndpoint.RowProcessorEndpoint<S extends com.google.protobuf.Message,T extends com.google.protobuf.Message>
extends org.apache.hadoop.hbase.coprocessor.BaseRowProcessorEndpoint<S,T>

This class defines two RowProcessors: IncrementCounterProcessor and FriendsOfFriendsProcessor. We define the RowProcessors as the inner class of the endpoint. So they can be loaded with the endpoint on the coprocessor.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TestRowProcessorEndpoint.RowProcessorEndpoint.FriendsOfFriendsProcessor
static class	TestRowProcessorEndpoint.RowProcessorEndpoint.IncrementCounterProcessor
static class	TestRowProcessorEndpoint.RowProcessorEndpoint.RowSwapProcessor
static class	TestRowProcessorEndpoint.RowProcessorEndpoint.TimeoutProcessor

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.protobuf.generated.RowProcessorProtos.RowProcessorService

org.apache.hadoop.hbase.protobuf.generated.RowProcessorProtos.RowProcessorService.BlockingInterface, org.apache.hadoop.hbase.protobuf.generated.RowProcessorProtos.RowProcessorService.Interface, org.apache.hadoop.hbase.protobuf.generated.RowProcessorProtos.RowProcessorService.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
RowProcessorEndpoint()

Method Summary

Modifier and Type	Method and Description
static void	doScan(org.apache.hadoop.hbase.regionserver.HRegion region, org.apache.hadoop.hbase.client.Scan scan, List<org.apache.hadoop.hbase.Cell> result)

Methods inherited from class org.apache.hadoop.hbase.coprocessor.BaseRowProcessorEndpoint

constructRowProcessorFromRequest, getServices, process, start, stop

Methods inherited from class org.apache.hadoop.hbase.protobuf.generated.RowProcessorProtos.RowProcessorService

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.RegionCoprocessor

getBulkLoadObserver, getEndpointObserver, getRegionObserver

Constructor Detail

RowProcessorEndpoint

public RowProcessorEndpoint()

Method Detail

doScan

public static void doScan(org.apache.hadoop.hbase.regionserver.HRegion region,
                          org.apache.hadoop.hbase.client.Scan scan,
                          List<org.apache.hadoop.hbase.Cell> result)
                   throws IOException

Throws:

IOException