@InterfaceAudience.LimitedPrivate(value="Coprocesssor") @InterfaceStability.Evolving public abstract class BaseRowProcessor<S extends com.google.protobuf.Message,T extends com.google.protobuf.Message> extends Object implements RowProcessor<S,T>
Constructor and Description |
---|
BaseRowProcessor() |
Modifier and Type | Method and Description |
---|---|
List<UUID> |
getClusterIds()
Returns The cluster ids that have the change.
|
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()
Returns The
Durability to use |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getRequestData, getResult, getRowsToLock, initialize, process, readOnly
public BaseRowProcessor()
public void preProcess(HRegion region, WALEdit walEdit) throws IOException
RowProcessor
preProcess
in interface RowProcessor<S extends com.google.protobuf.Message,T extends com.google.protobuf.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 com.google.protobuf.Message,T extends com.google.protobuf.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 com.google.protobuf.Message,T extends com.google.protobuf.Message>
IOException
public void postProcess(HRegion region, WALEdit walEdit, boolean success) throws IOException
RowProcessor
postProcess
in interface RowProcessor<S extends com.google.protobuf.Message,T extends com.google.protobuf.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()
RowProcessor
getClusterIds
in interface RowProcessor<S extends com.google.protobuf.Message,T extends com.google.protobuf.Message>
public String getName()
RowProcessor
getName
in interface RowProcessor<S extends com.google.protobuf.Message,T extends com.google.protobuf.Message>
public Durability useDurability()
RowProcessor
Durability
to useuseDurability
in interface RowProcessor<S extends com.google.protobuf.Message,T extends com.google.protobuf.Message>
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.