Class ClusterCompactionQueues
java.lang.Object
org.apache.hadoop.hbase.util.compaction.ClusterCompactionQueues
-
Field Summary
Modifier and TypeFieldDescriptionprivate final Set<ServerName>
private final Map<ServerName,
List<MajorCompactionRequest>> private final int
private final ReadWriteLock
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescription(package private) void
addToCompactionQueue
(ServerName serverName, MajorCompactionRequest info) (package private) boolean
(package private) int
(package private) Optional<ServerName>
(package private) List<MajorCompactionRequest>
getQueue
(ServerName serverName) (package private) boolean
(package private) void
releaseCompaction
(ServerName serverName) (package private) MajorCompactionRequest
reserveForCompaction
(ServerName serverName)
-
Field Details
-
compactionQueues
-
compactingServers
-
lock
-
concurrentServers
-
-
Constructor Details
-
ClusterCompactionQueues
ClusterCompactionQueues(int concurrentServers)
-
-
Method Details
-
addToCompactionQueue
-
hasWorkItems
boolean hasWorkItems() -
getCompactionRequestsLeftToFinish
-
getQueue
-
reserveForCompaction
-
releaseCompaction
-
atCapacity
boolean atCapacity() -
getLargestQueueFromServersNotCompacting
-