org.apache.hadoop.hbase.coprocessor

Class TestRowProcessorEndpoint.RowProcessorEndpoint.IncrementCounterProcessor

java.lang.Object

org.apache.hadoop.hbase.regionserver.BaseRowProcessor<org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.IncCounterProcessorRequest,org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.IncCounterProcessorResponse>

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

All Implemented Interfaces:

org.apache.hadoop.hbase.regionserver.RowProcessor<org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.IncCounterProcessorRequest,org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.IncCounterProcessorResponse>

Enclosing class:

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

public static class TestRowProcessorEndpoint.RowProcessorEndpoint.IncrementCounterProcessor
extends org.apache.hadoop.hbase.regionserver.BaseRowProcessor<org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.IncCounterProcessorRequest,org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.IncCounterProcessorResponse>

Field Summary

Fields

Modifier and Type	Field and Description
(package private) int	counter
(package private) byte[]	row

Constructor Summary

Constructors

Constructor and Description
IncrementCounterProcessor() Empty constructor for Writable
IncrementCounterProcessor(byte[] row)

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.IncCounterProcessorRequest	getRequestData()
org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.IncCounterProcessorResponse	getResult()
Collection<byte[]>	getRowsToLock()
void	initialize(org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.IncCounterProcessorRequest msg)
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

counter

int counter

row

byte[] row

Constructor Detail

IncrementCounterProcessor

IncrementCounterProcessor()

Empty constructor for Writable

IncrementCounterProcessor

IncrementCounterProcessor(byte[] row)

Method Detail

getRowsToLock

public Collection<byte[]> getRowsToLock()

getResult

public org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.IncCounterProcessorResponse 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.IncCounterProcessorRequest getRequestData()
                                                                                                                                     throws IOException

Throws:

IOException

initialize

public void initialize(org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.IncCounterProcessorRequest msg)