Package | Description |
---|---|
org.apache.hadoop.hbase.master.procedure | |
org.apache.hadoop.hbase.procedure2 |
Modifier and Type | Field and Description |
---|---|
private LockAndQueue |
SchemaLocking.metaLock |
Modifier and Type | Field and Description |
---|---|
private Map<String,LockAndQueue> |
SchemaLocking.namespaceLocks |
private Map<String,LockAndQueue> |
SchemaLocking.peerLocks |
private Map<String,LockAndQueue> |
SchemaLocking.regionLocks |
private Map<ServerName,LockAndQueue> |
SchemaLocking.serverLocks |
private Map<TableName,LockAndQueue> |
SchemaLocking.tableLocks |
Modifier and Type | Method and Description |
---|---|
private <T> LockAndQueue |
SchemaLocking.getLock(Map<T,LockAndQueue> map,
T key) |
(package private) LockAndQueue |
SchemaLocking.getMetaLock()
Deprecated.
only used for
RecoverMetaProcedure . Should be removed along with
RecoverMetaProcedure . |
(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 Type | Method and Description |
---|---|
private LockedResource |
SchemaLocking.createLockedResource(LockedResourceType resourceType,
String resourceName,
LockAndQueue queue) |
Modifier and Type | Method and Description |
---|---|
private <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) |
Modifier and Type | Method and Description |
---|---|
protected 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.
|
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.