io.druid.server.lookup.cache.loading

Class OffHeapLoadingCache<K,V>

java.lang.Object

io.druid.server.lookup.cache.loading.OffHeapLoadingCache<K,V>

All Implemented Interfaces:

LoadingCache<K,V>, Closeable, AutoCloseable

public class OffHeapLoadingCache<K,V>
extends Object
implements LoadingCache<K,V>

Constructor Summary

Constructors

Constructor and Description
OffHeapLoadingCache(double maxStoreSize, long maxEntriesSize, long expireAfterWrite, long expireAfterAccess)

Method Summary

Modifier and Type	Method and Description
void	close() Clean the used resources of the cache.
boolean	equals(Object o)
V	get(K key, Callable<? extends V> valueLoader) Returns the value associated with key in this cache, obtaining that value from valueLoader if necessary.
Map<K,V>	getAllPresent(Iterable<K> keys) Returns a map of the values associated with keys in this cache.
V	getIfPresent(K key)
LookupCacheStats	getStats()
int	hashCode()
void	invalidate(K key) Discards any cached value for key key.
void	invalidateAll() Clears the contents of the cache.
void	invalidateAll(Iterable<K> keys) Discards any cached values for keys keys.
boolean	isClosed()
void	putAll(Map<? extends K,? extends V> m) Copies all of the mappings from the specified map to the cache.

Methods inherited from class java.lang.Object

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

Constructor Detail

OffHeapLoadingCache

public OffHeapLoadingCache(double maxStoreSize,
                           long maxEntriesSize,
                           long expireAfterWrite,
                           long expireAfterAccess)

Method Detail

getIfPresent

public V getIfPresent(K key)

Specified by:

getIfPresent in interface LoadingCache<K,V>

Parameters:

key - must not be null Returns the value associated with key in this cache, or null if there is no cached value for key. a cache miss should be counted if the key is missing.

getAllPresent

public Map<K,V> getAllPresent(Iterable<K> keys)

Description copied from interface: LoadingCache

Returns a map of the values associated with keys in this cache. The returned map will only contain entries which are already present in the cache.

Specified by:

getAllPresent in interface LoadingCache<K,V>

get

public V get(K key,
             Callable<? extends V> valueLoader)
      throws ExecutionException

Description copied from interface: LoadingCache

Returns the value associated with key in this cache, obtaining that value from valueLoader if necessary. No observable state associated with this cache is modified until loading completes.

Warning: as with CacheLoader.load(K), valueLoader must not return null; it may either return a non-null value or throw an exception.

Specified by:

get in interface LoadingCache<K,V>

Throws:

ExecutionException - if a checked exception was thrown while loading the value

putAll

public void putAll(Map<? extends K,? extends V> m)

Description copied from interface: LoadingCache

Copies all of the mappings from the specified map to the cache. This method is used for bulk put.

Specified by:

putAll in interface LoadingCache<K,V>

invalidate

public void invalidate(K key)

Description copied from interface: LoadingCache

Discards any cached value for key key. Eviction can be lazy or eager.

Specified by:

invalidate in interface LoadingCache<K,V>

invalidateAll

public void invalidateAll(Iterable<K> keys)

Description copied from interface: LoadingCache

Discards any cached values for keys keys. Eviction can be lazy or eager.

Specified by:

invalidateAll in interface LoadingCache<K,V>

invalidateAll

public void invalidateAll()

Description copied from interface: LoadingCache

Clears the contents of the cache.

Specified by:

invalidateAll in interface LoadingCache<K,V>

getStats

public LookupCacheStats getStats()

Specified by:

getStats in interface LoadingCache<K,V>

Returns:

Stats of the cache.

isClosed

public boolean isClosed()

Specified by:

isClosed in interface LoadingCache<K,V>

Returns:

true if the Cache is closed

close

public void close()

Description copied from interface: LoadingCache

Clean the used resources of the cache. Still not sure about cache lifecycle but as an initial design the namespace deletion event should call this method to clean up resources.

Specified by:

close in interface LoadingCache<K,V>

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object