public class MiniBatchOperationInProgress<T>
extends java.lang.Object
org.apache.hadoop.hbase.coprocessor.RegionObserver#preBatchMutate(
org.apache.hadoop.hbase.coprocessor.ObserverContext, MiniBatchOperationInProgress)
,
org.apache.hadoop.hbase.coprocessor.RegionObserver#postBatchMutate(
org.apache.hadoop.hbase.coprocessor.ObserverContext, MiniBatchOperationInProgress)
Constructor and Description |
---|
MiniBatchOperationInProgress(T[] operations,
OperationStatus[] retCodeDetails,
WALEdit[] walEditsFromCoprocessors,
int firstIndex,
int lastIndexExclusive,
int readyToWriteCount) |
Modifier and Type | Method and Description |
---|---|
void |
addCellCount(int cellCount) |
void |
addOperationsFromCP(int index,
Mutation[] newOperations)
Add more Mutations corresponding to the Mutation at the given index to be committed atomically
in the same batch.
|
int |
getCellCount() |
int |
getLastIndexExclusive() |
int |
getNumOfDeletes() |
int |
getNumOfPuts() |
T |
getOperation(int index) |
Mutation[] |
getOperationsFromCoprocessors(int index) |
OperationStatus |
getOperationStatus(int index) |
int |
getReadyToWriteCount() |
WALEdit |
getWalEdit(int index) |
void |
incrementNumOfDeletes() |
void |
incrementNumOfPuts() |
void |
setOperationStatus(int index,
OperationStatus opStatus)
Sets the status code for the operation(Mutation) at the specified position.
|
void |
setWalEdit(int index,
WALEdit walEdit)
Sets the walEdit for the operation(Mutation) at the specified position.
|
int |
size() |
public MiniBatchOperationInProgress(T[] operations, OperationStatus[] retCodeDetails, WALEdit[] walEditsFromCoprocessors, int firstIndex, int lastIndexExclusive, int readyToWriteCount)
public int size()
public T getOperation(int index)
index
- public void setOperationStatus(int index, OperationStatus opStatus)
org.apache.hadoop.hbase.coprocessor.RegionObserver
can make HRegion to skip Mutations.index
- opStatus
- public OperationStatus getOperationStatus(int index)
index
- public void setWalEdit(int index, WALEdit walEdit)
index
- walEdit
- public WALEdit getWalEdit(int index)
index
- public void addOperationsFromCP(int index, Mutation[] newOperations)
index
- the index that corresponds to the original mutation index in the batchnewOperations
- the Mutations to addpublic Mutation[] getOperationsFromCoprocessors(int index)
public int getReadyToWriteCount()
public int getLastIndexExclusive()
public int getCellCount()
public void addCellCount(int cellCount)
public int getNumOfPuts()
public void incrementNumOfPuts()
public int getNumOfDeletes()
public void incrementNumOfDeletes()