ClusterCompactionQueues (Apache HBase 2.5.0 API)

@InterfaceAudience.Private
class ClusterCompactionQueues
extends Object

Fields
Modifier and Type	Field and Description
`private Set<ServerName>`	`compactingServers`
`private Map<ServerName,List<MajorCompactionRequest>>`	`compactionQueues`
`private int`	`concurrentServers`
`private ReadWriteLock`	`lock`

Constructors
Constructor and Description
`ClusterCompactionQueues(int concurrentServers)`

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`(package private) void`	`addToCompactionQueue(ServerName serverName, MajorCompactionRequest info)`
`(package private) boolean`	`atCapacity()`
`(package private) int`	`getCompactionRequestsLeftToFinish()`
`(package private) Optional<ServerName>`	`getLargestQueueFromServersNotCompacting()`
`(package private) List<MajorCompactionRequest>`	`getQueue(ServerName serverName)`
`(package private) boolean`	`hasWorkItems()`
`(package private) void`	`releaseCompaction(ServerName serverName)`
`(package private) MajorCompactionRequest`	`reserveForCompaction(ServerName serverName)`

private final Map<ServerName,List<MajorCompactionRequest>> compactionQueues

private final Set<ServerName> compactingServers

ClusterCompactionQueues(int concurrentServers)

void addToCompactionQueue(ServerName serverName,
                          MajorCompactionRequest info)

int getCompactionRequestsLeftToFinish()

List<MajorCompactionRequest> getQueue(ServerName serverName)

MajorCompactionRequest reserveForCompaction(ServerName serverName)

void releaseCompaction(ServerName serverName)

Optional<ServerName> getLargestQueueFromServersNotCompacting()

Class ClusterCompactionQueues