org.apache.hadoop.hbase.coprocessor

Class TestRowProcessorEndpoint.RowProcessorEndpoint.TimeoutProcessor

java.lang.Object

org.apache.hadoop.hbase.regionserver.BaseRowProcessor<org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.TimeoutProcessorRequest,org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.TimeoutProcessorResponse>

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

All Implemented Interfaces:

org.apache.hadoop.hbase.regionserver.RowProcessor<org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.TimeoutProcessorRequest,org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.TimeoutProcessorResponse>

Enclosing class:

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

public static class TestRowProcessorEndpoint.RowProcessorEndpoint.TimeoutProcessor
extends org.apache.hadoop.hbase.regionserver.BaseRowProcessor<org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.TimeoutProcessorRequest,org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.TimeoutProcessorResponse>

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

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

row

byte[] row

Constructor Detail

TimeoutProcessor

public TimeoutProcessor()

Empty constructor for Writable

TimeoutProcessor

public TimeoutProcessor(byte[] row)

Method Detail

getRowsToLock

public Collection<byte[]> getRowsToLock()

getResult

public org.apache.hadoop.hbase.coprocessor.protobuf.generated.IncrementCounterProcessorTestProtos.TimeoutProcessorResponse 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

readOnly

public boolean readOnly()

getName

public String getName()

Specified by:

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

Overrides:

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

getRequestData

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

Throws:

IOException

initialize

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

Throws:

IOException