org.apache.hadoop.hbase.regionserver

Class HRegion.ReplayBatchOperation

java.lang.Object

org.apache.hadoop.hbase.regionserver.HRegion.BatchOperation<WALSplitUtil.MutationReplay>

org.apache.hadoop.hbase.regionserver.HRegion.ReplayBatchOperation

Enclosing class:

HRegion

private static final class HRegion.ReplayBatchOperation
extends HRegion.BatchOperation<WALSplitUtil.MutationReplay>

Batch of mutations for replay. Base class is shared with HRegion.MutationBatchOperation 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	origLogSeqNum

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

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

Constructor Summary

Constructors

Constructor and Description
ReplayBatchOperation(HRegion region, WALSplitUtil.MutationReplay[] operations, long origLogSeqNum)

Method Summary

Modifier and Type	Method and Description
void	checkAndPrepare() Validates each mutation and prepares a batch for write.
protected void	checkAndPreparePut(Put p) During replay, there could exist column families which are removed between region server failure and replay
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.
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()
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, buildWALEdits, checkAndPrepareMutation, checkAndPrepareMutation, createMiniBatch, doPostOpCleanupForMiniBatch, 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

origLogSeqNum

private long origLogSeqNum

Constructor Detail

ReplayBatchOperation

public ReplayBatchOperation(HRegion region,
                            WALSplitUtil.MutationReplay[] operations,
                            long origLogSeqNum)

Method Detail

getMutation

public Mutation getMutation(int index)

Specified by:

getMutation in class HRegion.BatchOperation<WALSplitUtil.MutationReplay>

getNonceGroup

public long getNonceGroup(int index)

Specified by:

getNonceGroup in class HRegion.BatchOperation<WALSplitUtil.MutationReplay>

getNonce

public long getNonce(int index)

Specified by:

getNonce in class HRegion.BatchOperation<WALSplitUtil.MutationReplay>

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<WALSplitUtil.MutationReplay>

isInReplay

public boolean isInReplay()

Specified by:

isInReplay in class HRegion.BatchOperation<WALSplitUtil.MutationReplay>

getOrigLogSeqNum

public long getOrigLogSeqNum()

Specified by:

getOrigLogSeqNum in class HRegion.BatchOperation<WALSplitUtil.MutationReplay>

startRegionOperation

public void startRegionOperation()
                          throws IOException

Specified by:

startRegionOperation in class HRegion.BatchOperation<WALSplitUtil.MutationReplay>

Throws:

IOException

closeRegionOperation

public void closeRegionOperation()
                          throws IOException

Specified by:

closeRegionOperation in class HRegion.BatchOperation<WALSplitUtil.MutationReplay>

Throws:

IOException

checkAndPreparePut

protected void checkAndPreparePut(Put p)
                           throws IOException

During replay, there could exist column families which are removed between region server failure and replay

Specified by:

checkAndPreparePut in class HRegion.BatchOperation<WALSplitUtil.MutationReplay>

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()/preIncrement()/preAppend() 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<WALSplitUtil.MutationReplay>

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<WALSplitUtil.MutationReplay>

Throws:

IOException

writeMiniBatchOperationsToMemStore

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

Description copied from class: HRegion.BatchOperation

Write mini-batch operations to MemStore

Specified by:

writeMiniBatchOperationsToMemStore in class HRegion.BatchOperation<WALSplitUtil.MutationReplay>

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<WALSplitUtil.MutationReplay>

Throws:

IOException