Package org.apache.cassandra.utils.memory

Class MemtablePool

java.lang.Object

org.apache.cassandra.utils.memory.MemtablePool

Direct Known Subclasses:

HeapPool, HeapPool.Logged, NativePool, SlabPool

public abstract class MemtablePool
extends Object

Represents an amount of memory used for a given purpose, that can be allocated to specific tasks through child MemtableAllocator objects.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	MemtablePool.SubPool	Note the difference between acquire() and allocate(); allocate() makes more resources available to all owners, and acquire() makes shared resources unavailable but still recorded.

Field Summary

Fields

Modifier and Type	Field	Description
final com.codahale.metrics.Timer	blockedOnAllocating
final com.codahale.metrics.Gauge<Long>	numPendingTasks
final MemtablePool.SubPool	offHeap
final MemtablePool.SubPool	onHeap

Method Summary

Modifier and Type	Method	Description
Long	getNumPendingtasks()
boolean	needsCleaning()
abstract MemtableAllocator	newAllocator(String table)
void	shutdownAndWait(long timeout, TimeUnit unit)

Methods inherited from class java.lang.Object

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

Field Details

onHeap

public final MemtablePool.SubPool onHeap

offHeap

public final MemtablePool.SubPool offHeap

blockedOnAllocating

public final com.codahale.metrics.Timer blockedOnAllocating

numPendingTasks

public final com.codahale.metrics.Gauge<Long> numPendingTasks

Method Details

shutdownAndWait

public void shutdownAndWait(long timeout,
 TimeUnit unit)
                     throws InterruptedException,
TimeoutException

Throws:

InterruptedException

TimeoutException

newAllocator

public abstract MemtableAllocator newAllocator(String table)

needsCleaning

public boolean needsCleaning()

getNumPendingtasks

public Long getNumPendingtasks()