public static class TestRowProcessorEndpoint.RowProcessorEndpoint.TimeoutProcessor extends BaseRowProcessor<IncrementCounterProcessorTestProtos.TimeoutProcessorRequest,IncrementCounterProcessorTestProtos.TimeoutProcessorResponse>
Constructor and Description |
---|
TimeoutProcessor()
Empty constructor for Writable
|
TimeoutProcessor(byte[] row) |
Modifier and Type | Method and Description |
---|---|
String |
getName()
Human readable name of the processor
|
IncrementCounterProcessorTestProtos.TimeoutProcessorRequest |
getRequestData()
This method should return any additional data that is needed on the
server side to construct the RowProcessor.
|
IncrementCounterProcessorTestProtos.TimeoutProcessorResponse |
getResult()
Obtain the processing result.
|
Collection<byte[]> |
getRowsToLock()
Rows to lock while operation.
|
void |
initialize(IncrementCounterProcessorTestProtos.TimeoutProcessorRequest msg)
This method should initialize any field(s) of the RowProcessor with
a parsing of the passed message bytes (used on the server side).
|
void |
process(long now,
HRegion region,
List<Mutation> mutations,
WALEdit walEdit)
HRegion handles the locks and MVCC and invokes this method properly.
|
boolean |
readOnly()
Is this operation read only? If this is true, process() should not add
any mutations or it throws IOException.
|
getClusterIds, postBatchMutate, postProcess, preBatchMutate, preProcess, useDurability
public TimeoutProcessor()
public TimeoutProcessor(byte[] row)
public Collection<byte[]> getRowsToLock()
RowProcessor
RowProcessor
to avoid deadlock.public IncrementCounterProcessorTestProtos.TimeoutProcessorResponse getResult()
RowProcessor
public void process(long now, HRegion region, List<Mutation> mutations, WALEdit walEdit) throws IOException
RowProcessor
IsolationLevel.READ_UNCOMMITTED
for scan because
we advance MVCC after releasing the locks for optimization purpose.now
- the current system millisecondregion
- the HRegionmutations
- the output mutations to apply to memstorewalEdit
- the output WAL edits to apply to write ahead logIOException
public boolean readOnly()
RowProcessor
public String getName()
RowProcessor
getName
in interface RowProcessor<IncrementCounterProcessorTestProtos.TimeoutProcessorRequest,IncrementCounterProcessorTestProtos.TimeoutProcessorResponse>
getName
in class BaseRowProcessor<IncrementCounterProcessorTestProtos.TimeoutProcessorRequest,IncrementCounterProcessorTestProtos.TimeoutProcessorResponse>
public IncrementCounterProcessorTestProtos.TimeoutProcessorRequest getRequestData() throws IOException
RowProcessor
RowProcessor.initialize(Message msg)
method. If there is no RowProcessor
specific data then null should be returned.IOException
public void initialize(IncrementCounterProcessorTestProtos.TimeoutProcessorRequest msg) throws IOException
RowProcessor
IOException