public abstract class BaseRowProcessor<S extends Message,T extends Message> extends java.lang.Object implements RowProcessor<S,T>
Constructor and Description |
---|
BaseRowProcessor() |
Modifier and Type | Method and Description |
---|---|
java.util.List<java.util.UUID> |
getClusterIds() |
java.lang.String |
getName()
Human readable name of the processor
|
void |
postBatchMutate(HRegion region)
The hook to be executed after the process() and applying the Mutations to region.
|
void |
postProcess(HRegion region,
WALEdit walEdit,
boolean success)
The hook to be executed after process() and applying the Mutations to region.
|
void |
preBatchMutate(HRegion region,
WALEdit walEdit)
The hook to be executed after the process() but before applying the Mutations to region.
|
void |
preProcess(HRegion region,
WALEdit walEdit)
The hook to be executed before process().
|
Durability |
useDurability() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getRequestData, getResult, getRowsToLock, initialize, process, readOnly
public void preProcess(HRegion region, WALEdit walEdit) throws java.io.IOException
RowProcessor
preProcess
in interface RowProcessor<S extends Message,T extends Message>
region
- the HRegionwalEdit
- the output WAL edits to apply to write ahead logjava.io.IOException
public void preBatchMutate(HRegion region, WALEdit walEdit) throws java.io.IOException
RowProcessor
preBatchMutate
in interface RowProcessor<S extends Message,T extends Message>
walEdit
- the output WAL edits to apply to write ahead logjava.io.IOException
public void postBatchMutate(HRegion region) throws java.io.IOException
RowProcessor
RowProcessor.postProcess(HRegion, WALEdit, boolean)
is this hook will
be executed before the mvcc transaction completion.postBatchMutate
in interface RowProcessor<S extends Message,T extends Message>
java.io.IOException
public void postProcess(HRegion region, WALEdit walEdit, boolean success) throws java.io.IOException
RowProcessor
postProcess
in interface RowProcessor<S extends Message,T extends Message>
region
- the HRegionwalEdit
- the output WAL edits to apply to write ahead logsuccess
- true if batch operation is successful otherwise false.java.io.IOException
public java.util.List<java.util.UUID> getClusterIds()
getClusterIds
in interface RowProcessor<S extends Message,T extends Message>
public java.lang.String getName()
RowProcessor
getName
in interface RowProcessor<S extends Message,T extends Message>
public Durability useDurability()
useDurability
in interface RowProcessor<S extends Message,T extends Message>
Durability
to use