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() |
String |
getName()
Human readable name of the processor
|
void |
postProcess(HRegion region,
WALEdit walEdit)
The hook to be executed after process().
|
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 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 postProcess(HRegion region, WALEdit walEdit) 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 logIOException
public List<UUID> getClusterIds()
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()
useDurability
in interface RowProcessor<S extends com.google.protobuf.Message,T extends com.google.protobuf.Message>
Durability
to useCopyright © 2013 The Apache Software Foundation. All rights reserved.