org.apache.hadoop.hbase.coprocessor

Class TestCoprocessorInterface.CoprocessorImpl

java.lang.Object

org.apache.hadoop.hbase.coprocessor.TestCoprocessorInterface.CoprocessorImpl

All Implemented Interfaces:

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

Enclosing class:

TestCoprocessorInterface

public static class TestCoprocessorInterface.CoprocessorImpl
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 boolean	postCloseCalled
private boolean	postCompactCalled
private boolean	postFlushCalled
private boolean	postOpenCalled
private boolean	preCloseCalled
private boolean	preCompactCalled
private boolean	preFlushCalled
private boolean	preOpenCalled
private ConcurrentMap<String,Object>	sharedData
private boolean	startCalled
private boolean	stopCalled

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

PRIORITY_HIGHEST, PRIORITY_LOWEST, PRIORITY_SYSTEM, PRIORITY_USER, VERSION

Constructor Summary

Constructors

Constructor and Description
CoprocessorImpl()

Method Summary

Modifier and Type	Method and Description
Optional<org.apache.hadoop.hbase.coprocessor.RegionObserver>	getRegionObserver()
(package private) Map<String,Object>	getSharedData()
void	postClose(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e, boolean abortRequested)
void	postCompact(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e, org.apache.hadoop.hbase.regionserver.Store store, org.apache.hadoop.hbase.regionserver.StoreFile resultFile, org.apache.hadoop.hbase.regionserver.compactions.CompactionLifeCycleTracker tracker, org.apache.hadoop.hbase.regionserver.compactions.CompactionRequest request)
void	postFlush(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e, org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker)
void	postOpen(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e)
org.apache.hadoop.hbase.regionserver.RegionScanner	postScannerOpen(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e, org.apache.hadoop.hbase.client.Scan scan, org.apache.hadoop.hbase.regionserver.RegionScanner s)
void	preClose(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e, boolean abortRequested)
org.apache.hadoop.hbase.regionserver.InternalScanner	preCompact(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e, org.apache.hadoop.hbase.regionserver.Store store, org.apache.hadoop.hbase.regionserver.InternalScanner scanner, org.apache.hadoop.hbase.regionserver.ScanType scanType, org.apache.hadoop.hbase.regionserver.compactions.CompactionLifeCycleTracker tracker, org.apache.hadoop.hbase.regionserver.compactions.CompactionRequest request)
void	preFlush(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e, org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker)
void	preOpen(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e)
void	start(org.apache.hadoop.hbase.CoprocessorEnvironment e)
void	stop(org.apache.hadoop.hbase.CoprocessorEnvironment e)
(package private) boolean	wasClosed()
(package private) boolean	wasCompacted()
(package private) boolean	wasFlushed()
(package private) boolean	wasOpened()
(package private) boolean	wasStarted()
(package private) boolean	wasStopped()

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

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

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

Field Detail

startCalled

private boolean startCalled

stopCalled

private boolean stopCalled

preOpenCalled

private boolean preOpenCalled

postOpenCalled

private boolean postOpenCalled

preCloseCalled

private boolean preCloseCalled

postCloseCalled

private boolean postCloseCalled

preCompactCalled

private boolean preCompactCalled

postCompactCalled

private boolean postCompactCalled

preFlushCalled

private boolean preFlushCalled

postFlushCalled

private boolean postFlushCalled

sharedData

private ConcurrentMap<String,Object> sharedData

Constructor Detail

CoprocessorImpl

public CoprocessorImpl()

Method Detail

start

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

Specified by:

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

stop

public void stop(org.apache.hadoop.hbase.CoprocessorEnvironment e)

Specified by:

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

getRegionObserver

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

Specified by:

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

preOpen

public void preOpen(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e)

Specified by:

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

postOpen

public void postOpen(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e)

Specified by:

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

preClose

public void preClose(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e,
                     boolean abortRequested)

Specified by:

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

postClose

public void postClose(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e,
                      boolean abortRequested)

Specified by:

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

preCompact

public org.apache.hadoop.hbase.regionserver.InternalScanner preCompact(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e,
                                                                       org.apache.hadoop.hbase.regionserver.Store store,
                                                                       org.apache.hadoop.hbase.regionserver.InternalScanner scanner,
                                                                       org.apache.hadoop.hbase.regionserver.ScanType scanType,
                                                                       org.apache.hadoop.hbase.regionserver.compactions.CompactionLifeCycleTracker tracker,
                                                                       org.apache.hadoop.hbase.regionserver.compactions.CompactionRequest request)

Specified by:

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

postCompact

public void postCompact(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e,
                        org.apache.hadoop.hbase.regionserver.Store store,
                        org.apache.hadoop.hbase.regionserver.StoreFile resultFile,
                        org.apache.hadoop.hbase.regionserver.compactions.CompactionLifeCycleTracker tracker,
                        org.apache.hadoop.hbase.regionserver.compactions.CompactionRequest request)

Specified by:

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

preFlush

public void preFlush(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e,
                     org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker)

Specified by:

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

postFlush

public void postFlush(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e,
                      org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker)

Specified by:

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

postScannerOpen

public org.apache.hadoop.hbase.regionserver.RegionScanner postScannerOpen(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e,
                                                                          org.apache.hadoop.hbase.client.Scan scan,
                                                                          org.apache.hadoop.hbase.regionserver.RegionScanner s)
                                                                   throws IOException

Specified by:

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

Throws:

IOException

wasStarted

boolean wasStarted()

wasStopped

boolean wasStopped()

wasOpened

boolean wasOpened()

wasClosed

boolean wasClosed()

wasFlushed

boolean wasFlushed()

wasCompacted

boolean wasCompacted()

getSharedData

Map<String,Object> getSharedData()