Package 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
    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
    Description
    CoprocessorImpl()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    Optional<org.apache.hadoop.hbase.coprocessor.RegionObserver>
    getRegionObserver()
     
    (package private) Map<String,Object>
    getSharedData()
     
    void
    postClose(org.apache.hadoop.hbase.coprocessor.ObserverContext<? extends org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e, boolean abortRequested)
     
    void
    postCompact(org.apache.hadoop.hbase.coprocessor.ObserverContext<? extends 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<? extends org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e, org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker)
     
    void
    postOpen(org.apache.hadoop.hbase.coprocessor.ObserverContext<? extends org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e)
     
    org.apache.hadoop.hbase.regionserver.RegionScanner
    postScannerOpen(org.apache.hadoop.hbase.coprocessor.ObserverContext<? extends 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<? extends org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e, boolean abortRequested)
     
    org.apache.hadoop.hbase.regionserver.InternalScanner
    preCompact(org.apache.hadoop.hbase.coprocessor.ObserverContext<? extends 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<? extends org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e, org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker)
     
    void
    preOpen(org.apache.hadoop.hbase.coprocessor.ObserverContext<? extends 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

    getServices

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

    getBulkLoadObserver, getEndpointObserver

    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 Details

  • Constructor Details

  • Method Details

    • 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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()