Package org.apache.hadoop.hbase.util.compaction

Class ClusterCompactionQueues

java.lang.Object

org.apache.hadoop.hbase.util.compaction.ClusterCompactionQueues

@Private
class ClusterCompactionQueues
extends Object

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
ClusterCompactionQueues(int concurrentServers)

Method Summary

Modifier and Type	Method	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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

compactionQueues

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

compactingServers

private final Set<ServerName> compactingServers

lock

private final ReadWriteLock lock

concurrentServers

private final int concurrentServers

Constructor Details

ClusterCompactionQueues

ClusterCompactionQueues(int concurrentServers)

Method Details

addToCompactionQueue

void addToCompactionQueue(ServerName serverName,
 MajorCompactionRequest info)

hasWorkItems

boolean hasWorkItems()

getCompactionRequestsLeftToFinish

int getCompactionRequestsLeftToFinish()

getQueue

List<MajorCompactionRequest> getQueue(ServerName serverName)

reserveForCompaction

MajorCompactionRequest reserveForCompaction(ServerName serverName)

releaseCompaction

void releaseCompaction(ServerName serverName)

atCapacity

boolean atCapacity()

getLargestQueueFromServersNotCompacting

Optional<ServerName> getLargestQueueFromServersNotCompacting()