Package org.apache.hadoop.hbase.procedure2

Class TestStackIdHoles.DummyProcedureStore

java.lang.Object
org.apache.hadoop.hbase.procedure2.store.ProcedureStoreBase
org.apache.hadoop.hbase.procedure2.TestStackIdHoles.DummyProcedureStore
All Implemented Interfaces:
org.apache.hadoop.hbase.procedure2.store.ProcedureStore
Enclosing class:
TestStackIdHoles
private final class TestStackIdHoles.DummyProcedureStore extends org.apache.hadoop.hbase.procedure2.store.ProcedureStoreBase

  • Nested Class Summary

    Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.procedure2.store.ProcedureStore

    org.apache.hadoop.hbase.procedure2.store.ProcedureStore.ProcedureIterator, org.apache.hadoop.hbase.procedure2.store.ProcedureStore.ProcedureLoader, org.apache.hadoop.hbase.procedure2.store.ProcedureStore.ProcedureStoreListener

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    private final AtomicLong
    maxProcId
     
    private int
    numThreads
     
    private final LinkedHashMap<Long,org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.Procedure>
    procMap
     
    private final AtomicBoolean
    updated
     

  • Constructor Summary

    Constructors
    Modifier
    Constructor
    Description
    private
    DummyProcedureStore()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    delete(long procId)
     
    void
    delete(long[] procIds, int offset, int count)
     
    void
    delete(org.apache.hadoop.hbase.procedure2.Procedure<?> parentProc, long[] subProcIds)
     
    int
    getNumThreads()
     
    void
    insert(org.apache.hadoop.hbase.procedure2.Procedure<?>[] procs)
     
    void
    insert(org.apache.hadoop.hbase.procedure2.Procedure<?> proc, org.apache.hadoop.hbase.procedure2.Procedure<?>[] subprocs)
     
    void
    load(org.apache.hadoop.hbase.procedure2.store.ProcedureStore.ProcedureLoader loader)
     
    void
    recoverLease()
     
    int
    setRunningProcedureCount(int count)
     
    void
    start(int numThreads)
     
    void
    stop(boolean abort)
     
    void
    update(org.apache.hadoop.hbase.procedure2.Procedure<?> proc)
     

    Methods inherited from class org.apache.hadoop.hbase.procedure2.store.ProcedureStoreBase

    isRunning, registerListener, sendAbortProcessSignal, sendForceUpdateSignal, sendPostSyncSignal, setRunning, unregisterListener

    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.procedure2.store.ProcedureStore

    cleanup

  • Field Details

  • Constructor Details

  • Method Details

    • start

      public void start(int numThreads) throws IOException
      Throws:
      IOException

    • stop

      public void stop(boolean abort)

    • getNumThreads

      public int getNumThreads()

    • setRunningProcedureCount

      public int setRunningProcedureCount(int count)

    • recoverLease

      public void recoverLease() throws IOException
      Throws:
      IOException

    • load

      public void load(org.apache.hadoop.hbase.procedure2.store.ProcedureStore.ProcedureLoader loader) throws IOException
      Throws:
      IOException

    • insert

      public void insert(org.apache.hadoop.hbase.procedure2.Procedure<?> proc, org.apache.hadoop.hbase.procedure2.Procedure<?>[] subprocs)

    • insert

      public void insert(org.apache.hadoop.hbase.procedure2.Procedure<?>[] procs)

    • update

      public void update(org.apache.hadoop.hbase.procedure2.Procedure<?> proc)

    • delete

      public void delete(long procId)

    • delete

      public void delete(org.apache.hadoop.hbase.procedure2.Procedure<?> parentProc, long[] subProcIds)

    • delete

      public void delete(long[] procIds, int offset, int count)