private final class TestStackIdHoles.DummyProcedureStore extends org.apache.hadoop.hbase.procedure2.store.ProcedureStoreBase
org.apache.hadoop.hbase.procedure2.store.ProcedureStore.ProcedureIterator, org.apache.hadoop.hbase.procedure2.store.ProcedureStore.ProcedureLoader, org.apache.hadoop.hbase.procedure2.store.ProcedureStore.ProcedureStoreListener
Modifier and Type | Field and Description |
---|---|
private AtomicLong |
maxProcId |
private int |
numThreads |
private LinkedHashMap<Long,org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.Procedure> |
procMap |
private AtomicBoolean |
updated |
Modifier | Constructor and Description |
---|---|
private |
DummyProcedureStore() |
Modifier and Type | Method and 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) |
isRunning, registerListener, sendAbortProcessSignal, sendForceUpdateSignal, sendPostSyncSignal, setRunning, unregisterListener
private int numThreads
private final LinkedHashMap<Long,org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.Procedure> procMap
private final AtomicLong maxProcId
private final AtomicBoolean updated
private DummyProcedureStore()
public void start(int numThreads) throws IOException
IOException
public void stop(boolean abort)
public int getNumThreads()
public int setRunningProcedureCount(int count)
public void recoverLease() throws IOException
IOException
public void load(org.apache.hadoop.hbase.procedure2.store.ProcedureStore.ProcedureLoader loader) throws IOException
IOException
public void insert(org.apache.hadoop.hbase.procedure2.Procedure<?> proc, org.apache.hadoop.hbase.procedure2.Procedure<?>[] subprocs)
public void insert(org.apache.hadoop.hbase.procedure2.Procedure<?>[] procs)
public void update(org.apache.hadoop.hbase.procedure2.Procedure<?> proc)
public void delete(long procId)
public void delete(org.apache.hadoop.hbase.procedure2.Procedure<?> parentProc, long[] subProcIds)
public void delete(long[] procIds, int offset, int count)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.