Package org.apache.hadoop.hbase.regionserver

Class MiniBatchOperationInProgress<T>

java.lang.Object

org.apache.hadoop.hbase.regionserver.MiniBatchOperationInProgress<T>

Record Components:

T - Pair<Mutation, Integer> pair of Mutations and associated rowlock ids .

@LimitedPrivate("Coprocesssor")
public class MiniBatchOperationInProgress<T>
extends Object

Wraps together the mutations which are applied as a batch to the region and their operation status and WALEdits.

See Also:

• RegionObserver.preBatchMutate(org.apache.hadoop.hbase.coprocessor.ObserverContext, MiniBatchOperationInProgress)
• RegionObserver.postBatchMutate(org.apache.hadoop.hbase.coprocessor.ObserverContext, MiniBatchOperationInProgress)

Field Summary

Fields

Modifier and Type	Field	Description
private int	cellCount
private final int	firstIndex
private final int	lastIndexExclusive
private int	numOfAppends
private int	numOfDeletes
private int	numOfIncrements
private int	numOfPuts
private final T[]	operations
private Mutation[][]	operationsFromCoprocessors
private int	readyToWriteCount
private final OperationStatus[]	retCodeDetails
private WALEdit	walEditForReplicateIfExistsSkipWAL	Here is for HBASE-26993,saving the all the Mutations if there is Durability#SKIP_WAL in HRegion.BatchOperation#buildWALEdits for HRegion.doMiniBatchMutate(org.apache.hadoop.hbase.regionserver.HRegion.BatchOperation<?>) to also replicate Mutation which is Durability#SKIP_WAL to region replica.
private final WALEdit[]	walEditsFromCoprocessors

Constructor Summary

Constructors

Constructor	Description
MiniBatchOperationInProgress(T[] operations, OperationStatus[] retCodeDetails, WALEdit[] walEditsFromCoprocessors, int firstIndex, int lastIndexExclusive, int readyToWriteCount)

Method Summary

Modifier and Type	Method	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.
private int	getAbsoluteIndex(int index)
int	getCellCount()
int	getLastIndexExclusive()
int	getNumOfAppends()
int	getNumOfDeletes()
int	getNumOfIncrements()
int	getNumOfPuts()
T	getOperation(int index)	Returns The operation(Mutation) at the specified position.
Mutation[]	getOperationsFromCoprocessors(int index)
OperationStatus	getOperationStatus(int index)	Returns Gets the status code for the operation(Mutation) at the specified position.
int	getReadyToWriteCount()
WALEdit	getWalEdit(int index)	Returns Gets the walEdit for the operation(Mutation) at the specified position.
WALEdit	getWalEditForReplicateIfExistsSkipWAL()
void	incrementNumOfAppends()
void	incrementNumOfDeletes()
void	incrementNumOfIncrements()
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.
void	setWalEditForReplicateIfExistsSkipWAL(WALEdit walEditForReplicateSkipWAL)
int	size()	Returns The number of operations(Mutations) involved in this batch.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

operations

private final T[] operations

operationsFromCoprocessors

private Mutation[][] operationsFromCoprocessors

retCodeDetails

private final OperationStatus[] retCodeDetails

walEditsFromCoprocessors

private final WALEdit[] walEditsFromCoprocessors

firstIndex

private final int firstIndex

lastIndexExclusive

private final int lastIndexExclusive

readyToWriteCount

private int readyToWriteCount

cellCount

private int cellCount

numOfPuts

private int numOfPuts

numOfDeletes

private int numOfDeletes

numOfIncrements

private int numOfIncrements

numOfAppends

private int numOfAppends

walEditForReplicateIfExistsSkipWAL

private WALEdit walEditForReplicateIfExistsSkipWAL

Here is for HBASE-26993,saving the all the Mutations if there is Durability#SKIP_WAL in HRegion.BatchOperation#buildWALEdits for HRegion.doMiniBatchMutate(org.apache.hadoop.hbase.regionserver.HRegion.BatchOperation<?>) to also replicate Mutation which is Durability#SKIP_WAL to region replica.

Constructor Details

MiniBatchOperationInProgress

public MiniBatchOperationInProgress(T[] operations,
 OperationStatus[] retCodeDetails,
 WALEdit[] walEditsFromCoprocessors,
 int firstIndex,
 int lastIndexExclusive,
 int readyToWriteCount)

Method Details

size

public int size()

Returns The number of operations(Mutations) involved in this batch.

getOperation

public T getOperation(int index)

Returns The operation(Mutation) at the specified position.

setOperationStatus

public void setOperationStatus(int index,
 OperationStatus opStatus)

Sets the status code for the operation(Mutation) at the specified position. By setting this status, RegionObserver can make HRegion to skip Mutations.

getOperationStatus

public OperationStatus getOperationStatus(int index)

Returns Gets the status code for the operation(Mutation) at the specified position.

setWalEdit

public void setWalEdit(int index,
 WALEdit walEdit)

Sets the walEdit for the operation(Mutation) at the specified position.

getWalEdit

public WALEdit getWalEdit(int index)

Returns Gets the walEdit for the operation(Mutation) at the specified position.

getAbsoluteIndex

private int getAbsoluteIndex(int index)

addOperationsFromCP

public 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. These mutations are applied to the WAL and applied to the memstore as well. The timestamp of the cells in the given Mutations MUST be obtained from the original mutation. Note: The durability from CP will be replaced by the durability of corresponding mutation. Note: Currently only supports Put and Delete operations.

Parameters:

index - the index that corresponds to the original mutation index in the batch

newOperations - the Mutations to add

getOperationsFromCoprocessors

public Mutation[] getOperationsFromCoprocessors(int index)

getReadyToWriteCount

public int getReadyToWriteCount()

getLastIndexExclusive

public int getLastIndexExclusive()

getCellCount

public int getCellCount()

addCellCount

public void addCellCount(int cellCount)

getNumOfPuts

public int getNumOfPuts()

incrementNumOfPuts

public void incrementNumOfPuts()

getNumOfDeletes

public int getNumOfDeletes()

incrementNumOfDeletes

public void incrementNumOfDeletes()

getNumOfIncrements

public int getNumOfIncrements()

incrementNumOfIncrements

public void incrementNumOfIncrements()

getNumOfAppends

public int getNumOfAppends()

incrementNumOfAppends

public void incrementNumOfAppends()

getWalEditForReplicateIfExistsSkipWAL

public WALEdit getWalEditForReplicateIfExistsSkipWAL()

setWalEditForReplicateIfExistsSkipWAL

public void setWalEditForReplicateIfExistsSkipWAL(WALEdit walEditForReplicateSkipWAL)