org.apache.hadoop.hbase.regionserver

Class HRegion.MutationBatchOperation

java.lang.Object

org.apache.hadoop.hbase.regionserver.HRegion.BatchOperation<Mutation>

org.apache.hadoop.hbase.regionserver.HRegion.MutationBatchOperation

Enclosing class:

HRegion

static class HRegion.MutationBatchOperation
extends HRegion.BatchOperation<Mutation>

Batch of mutation operations. Base class is shared with HRegion.ReplayBatchOperation as most of the logic is same.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.regionserver.HRegion.BatchOperation

HRegion.BatchOperation.Visitor

Field Summary

Fields

Modifier and Type	Field and Description
private long	nonce
private long	nonceGroup

Fields inherited from class org.apache.hadoop.hbase.regionserver.HRegion.BatchOperation

atomic, durability, familyCellMaps, nextIndexToProcess, observedExceptions, operations, region, retCodeDetails, walEditsFromCoprocessors

Constructor Summary

Constructors

Constructor and Description
MutationBatchOperation(HRegion region, Mutation[] operations, boolean atomic, long nonceGroup, long nonce)

Method Summary

Modifier and Type	Method and Description
List<Pair<NonceKey,WALEdit>>	buildWALEdits(MiniBatchOperationInProgress<Mutation> miniBatchOp) Builds separate WALEdit per nonce by applying input mutations.
private void	callPreMutateCPHook(int index, WALEdit walEdit, int[] metrics) Runs prePut/ preDelete coprocessor hook for input mutation in a batch
private void	checkAndMergeCPMutations(MiniBatchOperationInProgress<Mutation> miniBatchOp, List<Region.RowLock> acquiredRowLocks, long timestamp)
void	checkAndPrepare() Validates each mutation and prepares a batch for write.
void	checkAndPreparePut(Put p) Implement any Put request specific check and prepare logic here.
void	closeRegionOperation()
void	completeMiniBatchOperations(MiniBatchOperationInProgress<Mutation> miniBatchOp, MultiVersionConcurrencyControl.WriteEntry writeEntry) This method completes mini-batch operations by calling postBatchMutate() CP hook (if required) and completing mvcc.
void	doPostOpCleanupForMiniBatch(MiniBatchOperationInProgress<Mutation> miniBatchOp, WALEdit walEdit, boolean success)
Mutation	getMutation(int index)
Mutation[]	getMutationsForCoprocs() This method is potentially expensive and useful mostly for non-replay CP path.
long	getNonce(int index)
long	getNonceGroup(int index)
long	getOrigLogSeqNum()
boolean	isInReplay()
private void	mergeFamilyMaps(Map<byte[],List<Cell>> familyMap, Map<byte[],List<Cell>> toBeMerged)
void	prepareMiniBatchOperations(MiniBatchOperationInProgress<Mutation> miniBatchOp, long timestamp, List<Region.RowLock> acquiredRowLocks) If necessary, calls preBatchMutate() CP hook for a mini-batch and updates metrics, cell count, tags and timestamp for all cells of all operations in a mini-batch.
void	startRegionOperation()
MultiVersionConcurrencyControl.WriteEntry	writeMiniBatchOperationsToMemStore(MiniBatchOperationInProgress<Mutation> miniBatchOp, MultiVersionConcurrencyControl.WriteEntry writeEntry) Write mini-batch operations to MemStore

Methods inherited from class org.apache.hadoop.hbase.regionserver.HRegion.BatchOperation

applyFamilyMapToMemStore, checkAndPrepareMutation, checkAndPrepareMutation, createMiniBatch, getClusterIds, isAtomic, isDone, isOperationPending, lockRowsAndBuildMiniBatch, size, visitBatchOperations, writeMiniBatchOperationsToMemStore

Methods inherited from class java.lang.Object

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

Field Detail

nonceGroup

private long nonceGroup

nonce

private long nonce

Constructor Detail

MutationBatchOperation

public MutationBatchOperation(HRegion region,
                              Mutation[] operations,
                              boolean atomic,
                              long nonceGroup,
                              long nonce)

Method Detail

getMutation

public Mutation getMutation(int index)

Specified by:

getMutation in class HRegion.BatchOperation<Mutation>

getNonceGroup

public long getNonceGroup(int index)

Specified by:

getNonceGroup in class HRegion.BatchOperation<Mutation>

getNonce

public long getNonce(int index)

Specified by:

getNonce in class HRegion.BatchOperation<Mutation>

getMutationsForCoprocs

public Mutation[] getMutationsForCoprocs()

Description copied from class: HRegion.BatchOperation

This method is potentially expensive and useful mostly for non-replay CP path.

Specified by:

getMutationsForCoprocs in class HRegion.BatchOperation<Mutation>

isInReplay

public boolean isInReplay()

Specified by:

isInReplay in class HRegion.BatchOperation<Mutation>

getOrigLogSeqNum

public long getOrigLogSeqNum()

Specified by:

getOrigLogSeqNum in class HRegion.BatchOperation<Mutation>

startRegionOperation

public void startRegionOperation()
                          throws IOException

Specified by:

startRegionOperation in class HRegion.BatchOperation<Mutation>

Throws:

IOException

closeRegionOperation

public void closeRegionOperation()
                          throws IOException

Specified by:

closeRegionOperation in class HRegion.BatchOperation<Mutation>

Throws:

IOException

checkAndPreparePut

public void checkAndPreparePut(Put p)
                        throws IOException

Description copied from class: HRegion.BatchOperation

Implement any Put request specific check and prepare logic here. Please refer to HRegion.BatchOperation.checkAndPrepareMutation(Mutation, long) for how its used.

Specified by:

checkAndPreparePut in class HRegion.BatchOperation<Mutation>

Throws:

IOException

checkAndPrepare

public void checkAndPrepare()
                     throws IOException

Description copied from class: HRegion.BatchOperation

Validates each mutation and prepares a batch for write. If necessary (non-replay case), runs CP prePut()/ preDelete() hooks for all mutations in a batch. This is intended to operate on entire batch and will be called from outside of class to check and prepare batch. This can be implemented by calling helper method HRegion.BatchOperation.checkAndPrepareMutation(int, long) in a 'for' loop over mutations.

Specified by:

checkAndPrepare in class HRegion.BatchOperation<Mutation>

Throws:

IOException

prepareMiniBatchOperations

public void prepareMiniBatchOperations(MiniBatchOperationInProgress<Mutation> miniBatchOp,
                                       long timestamp,
                                       List<Region.RowLock> acquiredRowLocks)
                                throws IOException

Description copied from class: HRegion.BatchOperation

If necessary, calls preBatchMutate() CP hook for a mini-batch and updates metrics, cell count, tags and timestamp for all cells of all operations in a mini-batch.

Specified by:

prepareMiniBatchOperations in class HRegion.BatchOperation<Mutation>

Throws:

IOException

buildWALEdits

public List<Pair<NonceKey,WALEdit>> buildWALEdits(MiniBatchOperationInProgress<Mutation> miniBatchOp)
                                           throws IOException

Description copied from class: HRegion.BatchOperation

Builds separate WALEdit per nonce by applying input mutations. If WALEdits from CP are present, they are merged to result WALEdit.

Overrides:

buildWALEdits in class HRegion.BatchOperation<Mutation>

Throws:

IOException

writeMiniBatchOperationsToMemStore

public MultiVersionConcurrencyControl.WriteEntry writeMiniBatchOperationsToMemStore(MiniBatchOperationInProgress<Mutation> miniBatchOp,
                                                                                    @Nullable
                                                                                    MultiVersionConcurrencyControl.WriteEntry writeEntry)
                                                                             throws IOException

Description copied from class: HRegion.BatchOperation

Write mini-batch operations to MemStore

Specified by:

writeMiniBatchOperationsToMemStore in class HRegion.BatchOperation<Mutation>

Throws:

IOException

completeMiniBatchOperations

public void completeMiniBatchOperations(MiniBatchOperationInProgress<Mutation> miniBatchOp,
                                        MultiVersionConcurrencyControl.WriteEntry writeEntry)
                                 throws IOException

Description copied from class: HRegion.BatchOperation

This method completes mini-batch operations by calling postBatchMutate() CP hook (if required) and completing mvcc.

Overrides:

completeMiniBatchOperations in class HRegion.BatchOperation<Mutation>

Throws:

IOException

doPostOpCleanupForMiniBatch

public void doPostOpCleanupForMiniBatch(MiniBatchOperationInProgress<Mutation> miniBatchOp,
                                        WALEdit walEdit,
                                        boolean success)
                                 throws IOException

Overrides:

doPostOpCleanupForMiniBatch in class HRegion.BatchOperation<Mutation>

Throws:

IOException

callPreMutateCPHook

private void callPreMutateCPHook(int index,
                                 WALEdit walEdit,
                                 int[] metrics)
                          throws IOException

Runs prePut/ preDelete coprocessor hook for input mutation in a batch

Parameters:

metrics - Array of 2 ints. index 0: count of puts and index 1: count of deletes

Throws:

IOException

checkAndMergeCPMutations

private void checkAndMergeCPMutations(MiniBatchOperationInProgress<Mutation> miniBatchOp,
                                      List<Region.RowLock> acquiredRowLocks,
                                      long timestamp)
                               throws IOException

Throws:

IOException

mergeFamilyMaps

private void mergeFamilyMaps(Map<byte[],List<Cell>> familyMap,
                             Map<byte[],List<Cell>> toBeMerged)