org.apache.hadoop.hbase.regionserver

Class TestRegionServerAbort.StopBlockingRegionObserver

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestRegionServerAbort.StopBlockingRegionObserver

All Implemented Interfaces:

org.apache.hadoop.hbase.Coprocessor, org.apache.hadoop.hbase.coprocessor.RegionCoprocessor, org.apache.hadoop.hbase.coprocessor.RegionObserver, org.apache.hadoop.hbase.coprocessor.RegionServerCoprocessor, org.apache.hadoop.hbase.coprocessor.RegionServerObserver

Enclosing class:

TestRegionServerAbort

public static class TestRegionServerAbort.StopBlockingRegionObserver
extends Object
implements org.apache.hadoop.hbase.coprocessor.RegionServerCoprocessor, org.apache.hadoop.hbase.coprocessor.RegionCoprocessor, org.apache.hadoop.hbase.coprocessor.RegionServerObserver, org.apache.hadoop.hbase.coprocessor.RegionObserver

Nested Class Summary

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

org.apache.hadoop.hbase.Coprocessor.State

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

org.apache.hadoop.hbase.coprocessor.RegionObserver.MutationType

Field Summary

Fields

Modifier and Type	Field and Description
private AtomicInteger	abortCount
static String	DO_ABORT
private boolean	stopAllowed

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

PRIORITY_HIGHEST, PRIORITY_LOWEST, PRIORITY_SYSTEM, PRIORITY_USER, VERSION

Constructor Summary

Constructors

Constructor and Description
StopBlockingRegionObserver()

Method Summary

Modifier and Type	Method and Description
int	getNumAbortsRequested()
Optional<org.apache.hadoop.hbase.coprocessor.RegionObserver>	getRegionObserver()
Optional<org.apache.hadoop.hbase.coprocessor.RegionServerObserver>	getRegionServerObserver()
void	prePut(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, org.apache.hadoop.hbase.client.Put put, org.apache.hadoop.hbase.wal.WALEdit edit, org.apache.hadoop.hbase.client.Durability durability)
void	preStopRegionServer(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionServerCoprocessorEnvironment> env)
void	setStopAllowed(boolean allowed)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.coprocessor.RegionCoprocessor

getBulkLoadObserver, getEndpointObserver

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

getServices, start, stop

Methods inherited from interface org.apache.hadoop.hbase.coprocessor.RegionServerObserver

postClearCompactionQueues, postCreateReplicationEndPoint, postExecuteProcedures, postReplicateLogEntries, postRollWALWriterRequest, preClearCompactionQueues, preExecuteProcedures, preReplicateLogEntries, preRollWALWriterRequest

Methods inherited from interface org.apache.hadoop.hbase.coprocessor.RegionObserver

postAppend, postAppend, postAppendBeforeWAL, postBatchMutate, postBatchMutateIndispensably, postBulkLoadHFile, postCheckAndDelete, postCheckAndDelete, postCheckAndMutate, postCheckAndPut, postCheckAndPut, postClose, postCloseRegionOperation, postCommitStoreFile, postCompact, postCompactSelection, postDelete, postDelete, postExists, postFlush, postFlush, postGetOp, postIncrement, postIncrement, postIncrementBeforeWAL, postInstantiateDeleteTracker, postMemStoreCompaction, postMutationBeforeWAL, postOpen, postPut, postPut, postReplayWALs, postScannerClose, postScannerFilterRow, postScannerNext, postScannerOpen, postStartRegionOperation, postStoreFileReaderOpen, postWALRestore, preAppend, preAppend, preAppendAfterRowLock, preBatchMutate, preBulkLoadHFile, preCheckAndDelete, preCheckAndDelete, preCheckAndDeleteAfterRowLock, preCheckAndDeleteAfterRowLock, preCheckAndMutate, preCheckAndMutateAfterRowLock, preCheckAndPut, preCheckAndPut, preCheckAndPutAfterRowLock, preCheckAndPutAfterRowLock, preClose, preCommitStoreFile, preCompact, preCompactScannerOpen, preCompactSelection, preDelete, preDelete, preExists, preFlush, preFlush, preFlushScannerOpen, preGetOp, preIncrement, preIncrement, preIncrementAfterRowLock, preMemStoreCompaction, preMemStoreCompactionCompact, preMemStoreCompactionCompactScannerOpen, preOpen, prePrepareTimeStampForDeleteVersion, prePut, preReplayWALs, preScannerClose, preScannerNext, preScannerOpen, preStoreFileReaderOpen, preStoreScannerOpen, preWALAppend, preWALRestore

Field Detail

DO_ABORT

public static final String DO_ABORT

See Also:

Constant Field Values

stopAllowed

private boolean stopAllowed

abortCount

private AtomicInteger abortCount

Constructor Detail

StopBlockingRegionObserver

public StopBlockingRegionObserver()

Method Detail

getRegionObserver

public Optional<org.apache.hadoop.hbase.coprocessor.RegionObserver> getRegionObserver()

Specified by:

getRegionObserver in interface org.apache.hadoop.hbase.coprocessor.RegionCoprocessor

getRegionServerObserver

public Optional<org.apache.hadoop.hbase.coprocessor.RegionServerObserver> getRegionServerObserver()

Specified by:

getRegionServerObserver in interface org.apache.hadoop.hbase.coprocessor.RegionServerCoprocessor

prePut

public void prePut(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c,
                   org.apache.hadoop.hbase.client.Put put,
                   org.apache.hadoop.hbase.wal.WALEdit edit,
                   org.apache.hadoop.hbase.client.Durability durability)
            throws IOException

Specified by:

prePut in interface org.apache.hadoop.hbase.coprocessor.RegionObserver

Throws:

IOException

preStopRegionServer

public void preStopRegionServer(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionServerCoprocessorEnvironment> env)
                         throws IOException

Specified by:

preStopRegionServer in interface org.apache.hadoop.hbase.coprocessor.RegionServerObserver

Throws:

IOException

getNumAbortsRequested

public int getNumAbortsRequested()

setStopAllowed

public void setStopAllowed(boolean allowed)