org.apache.hadoop.hbase.thrift2

Class TestThriftHBaseServiceHandler.DelayingRegionObserver

java.lang.Object

org.apache.hadoop.hbase.thrift2.TestThriftHBaseServiceHandler.DelayingRegionObserver

All Implemented Interfaces:

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

Enclosing class:

TestThriftHBaseServiceHandler

public static class TestThriftHBaseServiceHandler.DelayingRegionObserver
extends Object
implements org.apache.hadoop.hbase.coprocessor.RegionCoprocessor, 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 long	delayMillis
private static org.slf4j.Logger	LOG

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

PRIORITY_HIGHEST, PRIORITY_LOWEST, PRIORITY_SYSTEM, PRIORITY_USER, VERSION

Constructor Summary

Constructors

Constructor and Description
DelayingRegionObserver()

Method Summary

Modifier and Type	Method and Description
Optional<org.apache.hadoop.hbase.coprocessor.RegionObserver>	getRegionObserver()
void	preGetOp(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e, org.apache.hadoop.hbase.client.Get get, List<org.apache.hadoop.hbase.Cell> results)
void	start(org.apache.hadoop.hbase.CoprocessorEnvironment e)

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, stop

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, preIncrement, preIncrement, preIncrementAfterRowLock, preMemStoreCompaction, preMemStoreCompactionCompact, preMemStoreCompactionCompactScannerOpen, preOpen, prePrepareTimeStampForDeleteVersion, prePut, prePut, preReplayWALs, preScannerClose, preScannerNext, preScannerOpen, preStoreFileReaderOpen, preStoreScannerOpen, preWALAppend, preWALRestore

Field Detail

LOG

private static final org.slf4j.Logger LOG

delayMillis

private long delayMillis

Constructor Detail

DelayingRegionObserver

public DelayingRegionObserver()

Method Detail

getRegionObserver

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

Specified by:

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

start

public void start(org.apache.hadoop.hbase.CoprocessorEnvironment e)
           throws IOException

Specified by:

start in interface org.apache.hadoop.hbase.Coprocessor

Throws:

IOException

preGetOp

public void preGetOp(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e,
                     org.apache.hadoop.hbase.client.Get get,
                     List<org.apache.hadoop.hbase.Cell> results)
              throws IOException

Specified by:

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

Throws:

IOException