@InterfaceAudience.LimitedPrivate(value="Coprocesssor") @InterfaceStability.Evolving public abstract class BaseRowProcessor<S extends Message,T extends Message> extends Object implements RowProcessor<S,T>
Constructor and Description |
---|
BaseRowProcessor() |
Modifier and Type | Method and Description |
---|---|
List<UUID> |
getClusterIds() |
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 IOException
RowProcessor
preProcess
in interface RowProcessor<S extends Message,T extends Message>
region
- the HRegionwalEdit
- the output WAL edits to apply to write ahead logIOException
public void preBatchMutate(HRegion region, WALEdit walEdit) throws IOException
RowProcessor
preBatchMutate
in interface RowProcessor<S extends Message,T extends Message>
walEdit
- the output WAL edits to apply to write ahead logIOException
public void postBatchMutate(HRegion region) throws 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>
IOException
public void postProcess(HRegion region, WALEdit walEdit, boolean success) throws 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.IOException
public List<UUID> getClusterIds()
getClusterIds
in interface RowProcessor<S extends Message,T extends Message>
public 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