Package org.apache.cassandra.cache

Class AutoSavingCache<K extends CacheKey,V>

java.lang.Object

org.apache.cassandra.cache.InstrumentingCache<K,V>

org.apache.cassandra.cache.AutoSavingCache<K,V>

public class AutoSavingCache<K extends CacheKey,V>
extends InstrumentingCache<K,V>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AutoSavingCache.CacheSerializer<K extends CacheKey,V>	A base cache serializer that is used to serialize/deserialize a cache to/from disk.
static interface	AutoSavingCache.IStreamFactory
class	AutoSavingCache.Writer

Field Summary

Fields

Modifier and Type	Field	Description
protected final CacheService.CacheType	cacheType
static final Set<CacheService.CacheType>	flushInProgress	True if a cache flush is currently executing: only one may execute at a time.
protected ScheduledFuture<?>	saveTask

Constructor Summary

Constructors

Constructor	Description
AutoSavingCache(ICache<K,V> cache, CacheService.CacheType cacheType, AutoSavingCache.CacheSerializer<K,V> cacheloader)

Method Summary

Modifier and Type	Method	Description
File	getCacheCrcPath(String version)
File	getCacheDataPath(String version)
File	getCacheMetadataPath(String version)
AutoSavingCache<K,V>.Writer	getWriter(int keysToSave)
int	loadSaved()
Future<Integer>	loadSavedAsync()
void	scheduleSaving(int savePeriodInSeconds, int keysToSave)
static void	setStreamFactory(AutoSavingCache.IStreamFactory streamFactory)
Future<?>	submitWrite(int keysToSave)

Methods inherited from class org.apache.cassandra.cache.InstrumentingCache

clear, containsKey, get, getCapacity, getInternal, getMetrics, hotKeyIterator, keyIterator, put, putIfAbsent, remove, replace, setCapacity, size, weightedSize

Methods inherited from class java.lang.Object

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

Field Details

flushInProgress

public static final Set<CacheService.CacheType> flushInProgress

True if a cache flush is currently executing: only one may execute at a time.

saveTask

protected volatile ScheduledFuture<?> saveTask

cacheType

protected final CacheService.CacheType cacheType

Constructor Details

AutoSavingCache

public AutoSavingCache(ICache<K,V> cache,
 CacheService.CacheType cacheType,
 AutoSavingCache.CacheSerializer<K,V> cacheloader)

Method Details

setStreamFactory

public static void setStreamFactory(AutoSavingCache.IStreamFactory streamFactory)

getCacheDataPath

public File getCacheDataPath(String version)

getCacheCrcPath

public File getCacheCrcPath(String version)

getCacheMetadataPath

public File getCacheMetadataPath(String version)

getWriter

public AutoSavingCache<K,V>.Writer getWriter(int keysToSave)

scheduleSaving

public void scheduleSaving(int savePeriodInSeconds,
 int keysToSave)

loadSavedAsync

public Future<Integer> loadSavedAsync()

loadSaved

public int loadSaved()

submitWrite

public Future<?> submitWrite(int keysToSave)