Uses of Class
org.apache.hadoop.hbase.procedure2.LockAndQueue
-
Uses of LockAndQueue in org.apache.hadoop.hbase.master.procedure
Modifier and TypeFieldDescriptionprivate final Map<String,
LockAndQueue> SchemaLocking.namespaceLocks
private final Map<String,
LockAndQueue> SchemaLocking.peerLocks
private final Map<String,
LockAndQueue> SchemaLocking.regionLocks
private final Map<ServerName,
LockAndQueue> SchemaLocking.serverLocks
private final Map<TableName,
LockAndQueue> SchemaLocking.tableLocks
Modifier and TypeMethodDescriptionprivate <T> LockAndQueue
SchemaLocking.getLock
(Map<T, LockAndQueue> map, T key) (package private) LockAndQueue
SchemaLocking.getMetaLock()
Deprecated.(package private) LockAndQueue
SchemaLocking.getNamespaceLock
(String namespace) (package private) LockAndQueue
SchemaLocking.getPeerLock
(String peerId) (package private) LockAndQueue
SchemaLocking.getRegionLock
(String encodedRegionName) (package private) LockAndQueue
SchemaLocking.getServerLock
(ServerName serverName) (package private) LockAndQueue
SchemaLocking.getTableLock
(TableName tableName) (package private) LockAndQueue
SchemaLocking.removePeerLock
(String peerId) (package private) LockAndQueue
SchemaLocking.removeRegionLock
(String encodedRegionName) (package private) LockAndQueue
SchemaLocking.removeServerLock
(ServerName serverName) (package private) LockAndQueue
SchemaLocking.removeTableLock
(TableName tableName) Modifier and TypeMethodDescriptionprivate LockedResource
SchemaLocking.createLockedResource
(LockedResourceType resourceType, String resourceName, LockAndQueue queue) Modifier and TypeMethodDescriptionprivate <T> void
SchemaLocking.addToLockedResources
(List<LockedResource> lockedResources, Map<T, LockAndQueue> locks, Function<T, String> keyTransformer, LockedResourceType resourcesType) private String
SchemaLocking.filterUnlocked
(Map<?, LockAndQueue> locks) private <T> LockAndQueue
SchemaLocking.getLock
(Map<T, LockAndQueue> map, T key) -
Uses of LockAndQueue in org.apache.hadoop.hbase.procedure2
Modifier and TypeMethodDescriptionprotected void
AbstractProcedureScheduler.waitProcedure
(LockAndQueue lockAndQueue, Procedure proc) protected int
AbstractProcedureScheduler.wakeWaitingProcedures
(LockAndQueue lockAndQueue) Wakes up given waiting procedures by pushing them back into scheduler queues.
RecoverMetaProcedure
.