org.apache.hadoop.hbase.coprocessor

Class TestRowProcessorEndpoint.RowProcessorEndpoint.RowSwapProcessor

java.lang.Object

org.apache.hadoop.hbase.regionserver.BaseRowProcessor<org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.RowSwapProcessorRequest,org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.RowSwapProcessorResponse>

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

All Implemented Interfaces:

org.apache.hadoop.hbase.regionserver.RowProcessor<org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.RowSwapProcessorRequest,org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.RowSwapProcessorResponse>

Enclosing class:

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

public static class TestRowProcessorEndpoint.RowProcessorEndpoint.RowSwapProcessor
extends org.apache.hadoop.hbase.regionserver.BaseRowProcessor<org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.RowSwapProcessorRequest,org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.RowSwapProcessorResponse>

Field Summary

Fields

Modifier and Type	Field and Description
(package private) byte[]	row1
(package private) byte[]	row2

Constructor Summary

Constructors

Constructor and Description
RowSwapProcessor() Empty constructor for Writable
RowSwapProcessor(byte[] row1, byte[] row2)

Method Summary

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

row1

byte[] row1

row2

byte[] row2

Constructor Detail

RowSwapProcessor

RowSwapProcessor()

Empty constructor for Writable

RowSwapProcessor

RowSwapProcessor(byte[] row1,
                 byte[] row2)

Method Detail

getRowsToLock

public Collection<byte[]> getRowsToLock()

readOnly

public boolean readOnly()

getResult

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

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

getName

public String getName()

Specified by:

getName in interface org.apache.hadoop.hbase.regionserver.RowProcessor<org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.RowSwapProcessorRequest,org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.RowSwapProcessorResponse>

Overrides:

getName in class org.apache.hadoop.hbase.regionserver.BaseRowProcessor<org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.RowSwapProcessorRequest,org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.RowSwapProcessorResponse>

getRequestData

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

Throws:

IOException

initialize

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