org.apache.hadoop.hbase.regionserver

Class TestSplitTransactionOnCluster.MockedRegionObserver

java.lang.Object

org.apache.hadoop.hbase.coprocessor.BaseRegionObserver

org.apache.hadoop.hbase.regionserver.TestSplitTransactionOnCluster.MockedRegionObserver

All Implemented Interfaces:

Coprocessor, RegionObserver

Enclosing class:

TestSplitTransactionOnCluster

public static class TestSplitTransactionOnCluster.MockedRegionObserver
extends BaseRegionObserver

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.coprocessor.RegionObserver

RegionObserver.MutationType

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.Coprocessor

Coprocessor.State

Field Summary

Fields inherited from interface org.apache.hadoop.hbase.Coprocessor

PRIORITY_HIGHEST, PRIORITY_LOWEST, PRIORITY_SYSTEM, PRIORITY_USER, VERSION

Constructor Summary

Constructors

Constructor and Description
MockedRegionObserver()

Method Summary

Modifier and Type	Method and Description
void	preSplitAfterPONR(ObserverContext<RegionCoprocessorEnvironment> ctx) This will be called after PONR step as part of split transaction Calling ObserverContext.bypass() has no effect in this hook.
void	preSplitBeforePONR(ObserverContext<RegionCoprocessorEnvironment> ctx, byte[] splitKey, List<Mutation> metaEntries) This will be called before PONR step as part of split transaction.

Methods inherited from class org.apache.hadoop.hbase.coprocessor.BaseRegionObserver

postAppend, postBatchMutate, postBatchMutateIndispensably, postBulkLoadHFile, postBulkLoadHFile, postCheckAndDelete, postCheckAndPut, postClose, postCloseRegionOperation, postCommitStoreFile, postCompact, postCompact, postCompactSelection, postCompactSelection, postCompleteSplit, postDelete, postExists, postFlush, postFlush, postGetClosestRowBefore, postGetOp, postIncrement, postIncrementColumnValue, postInstantiateDeleteTracker, postLogReplay, postMutationBeforeWAL, postOpen, postPut, postRollBackSplit, postScannerClose, postScannerFilterRow, postScannerNext, postScannerOpen, postSplit, postStartRegionOperation, postStoreFileReaderOpen, postWALRestore, postWALRestore, preAppend, preAppendAfterRowLock, preBatchMutate, preBulkLoadHFile, preCheckAndDelete, preCheckAndDeleteAfterRowLock, preCheckAndPut, preCheckAndPutAfterRowLock, preClose, preCommitStoreFile, preCompact, preCompact, preCompactScannerOpen, preCompactScannerOpen, preCompactSelection, preCompactSelection, preDelete, preExists, preFlush, preFlush, preFlushScannerOpen, preGetClosestRowBefore, preGetOp, preIncrement, preIncrementAfterRowLock, preIncrementColumnValue, preOpen, prePrepareTimeStampForDeleteVersion, prePut, preRollBackSplit, preScannerClose, preScannerNext, preScannerOpen, preSplit, preSplit, preStoreFileReaderOpen, preStoreScannerOpen, preWALRestore, preWALRestore, start, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

MockedRegionObserver

public MockedRegionObserver()

Method Detail

preSplitBeforePONR

public void preSplitBeforePONR(ObserverContext<RegionCoprocessorEnvironment> ctx,
                               byte[] splitKey,
                               List<Mutation> metaEntries)
                        throws IOException

Description copied from interface: RegionObserver

This will be called before PONR step as part of split transaction. Calling ObserverContext.bypass() rollback the split

Specified by:

preSplitBeforePONR in interface RegionObserver

Overrides:

preSplitBeforePONR in class BaseRegionObserver

Throws:

IOException

preSplitAfterPONR

public void preSplitAfterPONR(ObserverContext<RegionCoprocessorEnvironment> ctx)
                       throws IOException

Description copied from interface: RegionObserver

This will be called after PONR step as part of split transaction Calling ObserverContext.bypass() has no effect in this hook.

Specified by:

preSplitAfterPONR in interface RegionObserver

Overrides:

preSplitAfterPONR in class BaseRegionObserver

Throws:

IOException