com.indeed.lsmtree.recordcache

Class MemcachedMappingRecordCache<A,B,C,D>

java.lang.Object

com.indeed.lsmtree.recordcache.MemcachedMappingRecordCache<A,B,C,D>

All Implemented Interfaces:

RecordCache<C,D>, Closeable, AutoCloseable

public final class MemcachedMappingRecordCache<A,B,C,D>
extends Object
implements RecordCache<C,D>

Author:

jplaisance

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MemcachedMappingRecordCache.Builder<A,B,C,D>
static class	MemcachedMappingRecordCache.PrimerStatus

Constructor Summary

Constructors

Constructor and Description
MemcachedMappingRecordCache(PersistentRecordCache<A,B> baseCache, fj.F<A,C> aToCFunction, fj.F<C,A> cToAFunction, fj.F<B,D> valueMapFunction, MemcachedCache<C,D> memcachedCache)

Method Summary

Modifier and Type	Method and Description
boolean	checkAvailability(String key)
void	close()
D	get(C key, CacheStats cacheStats)
Map<C,D>	getAll(Collection<C> keys, CacheStats cacheStats)
RecordLogDirectoryPoller.Functions	getFunctions()
String	getLsmTreeMissCounter()
String	getMemcacheMissCounter()
Map<String,String>	getStats()
void	prime(Iterator<C> keys, MemcachedMappingRecordCache.PrimerStatus status)
void	removeFromCache(C key)

Methods inherited from class java.lang.Object

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

Constructor Detail

MemcachedMappingRecordCache

public MemcachedMappingRecordCache(PersistentRecordCache<A,B> baseCache,
                                   fj.F<A,C> aToCFunction,
                                   fj.F<C,A> cToAFunction,
                                   fj.F<B,D> valueMapFunction,
                                   MemcachedCache<C,D> memcachedCache)

Method Detail

get

public D get(C key,
             CacheStats cacheStats)

Specified by:

get in interface RecordCache<C,D>

getAll

public Map<C,D> getAll(Collection<C> keys,
                       CacheStats cacheStats)

Specified by:

getAll in interface RecordCache<C,D>

getFunctions

public RecordLogDirectoryPoller.Functions getFunctions()

Specified by:

getFunctions in interface RecordCache<C,D>

removeFromCache

public void removeFromCache(C key)

getStats

public Map<String,String> getStats()

prime

public void prime(Iterator<C> keys,
                  @Nullable
                  MemcachedMappingRecordCache.PrimerStatus status)
           throws IndexReadException

Throws:

IndexReadException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

checkAvailability

public boolean checkAvailability(String key)

getMemcacheMissCounter

public String getMemcacheMissCounter()

getLsmTreeMissCounter

public String getLsmTreeMissCounter()