org.apache.hadoop.hbase.coprocessor

Class TestRowProcessorEndpoint.RowProcessorEndpoint.FriendsOfFriendsProcessor

java.lang.Object

org.apache.hadoop.hbase.regionserver.BaseRowProcessor<org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.FriendsOfFriendsProcessorRequest,org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.FriendsOfFriendsProcessorResponse>

org.apache.hadoop.hbase.coprocessor.TestRowProcessorEndpoint.RowProcessorEndpoint.FriendsOfFriendsProcessor

All Implemented Interfaces:

org.apache.hadoop.hbase.regionserver.RowProcessor<org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.FriendsOfFriendsProcessorRequest,org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.FriendsOfFriendsProcessorResponse>

Enclosing class:

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

public static class TestRowProcessorEndpoint.RowProcessorEndpoint.FriendsOfFriendsProcessor
extends org.apache.hadoop.hbase.regionserver.BaseRowProcessor<org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.FriendsOfFriendsProcessorRequest,org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.FriendsOfFriendsProcessorResponse>

Field Summary

Fields

Modifier and Type	Field and Description
(package private) byte[]	person
(package private) Set<String>	result
(package private) byte[]	row

Constructor Summary

Constructors

Constructor and Description
FriendsOfFriendsProcessor() Empty constructor for Writable
FriendsOfFriendsProcessor(byte[] row, byte[] person)

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.FriendsOfFriendsProcessorRequest	getRequestData()
org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.FriendsOfFriendsProcessorResponse	getResult()
Collection<byte[]>	getRowsToLock()
void	initialize(org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.FriendsOfFriendsProcessorRequest request)
void	process(long now, org.apache.hadoop.hbase.regionserver.HRegion region, List<org.apache.hadoop.hbase.client.Mutation> mutations, org.apache.hadoop.hbase.wal.WALEdit walEdit)
boolean	readOnly()

Methods inherited from class org.apache.hadoop.hbase.regionserver.BaseRowProcessor

getClusterIds, getName, postBatchMutate, postProcess, preBatchMutate, preProcess, useDurability

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

row

byte[] row

person

byte[] person

result

final Set<String> result

Constructor Detail

FriendsOfFriendsProcessor

FriendsOfFriendsProcessor()

Empty constructor for Writable

FriendsOfFriendsProcessor

FriendsOfFriendsProcessor(byte[] row,
                          byte[] person)

Method Detail

getRowsToLock

public Collection<byte[]> getRowsToLock()

getResult

public org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.FriendsOfFriendsProcessorResponse getResult()

readOnly

public boolean readOnly()

process

public void process(long now,
                    org.apache.hadoop.hbase.regionserver.HRegion region,
                    List<org.apache.hadoop.hbase.client.Mutation> mutations,
                    org.apache.hadoop.hbase.wal.WALEdit walEdit)
             throws IOException

Throws:

IOException

getRequestData

public org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.FriendsOfFriendsProcessorRequest getRequestData()
                                                                                                                                           throws IOException

Throws:

IOException

initialize

public void initialize(org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.FriendsOfFriendsProcessorRequest request)
                throws IOException

Throws:

IOException