io.druid.server.namespace.cache

Class OffHeapNamespaceExtractionCacheManager

java.lang.Object

io.druid.server.namespace.cache.NamespaceExtractionCacheManager

io.druid.server.namespace.cache.OffHeapNamespaceExtractionCacheManager

public class OffHeapNamespaceExtractionCacheManager
extends NamespaceExtractionCacheManager

Field Summary

Fields inherited from class io.druid.server.namespace.cache.NamespaceExtractionCacheManager

dataSize, fnCache, implData, serviceEmitter, tasksStarted

Constructor Summary

Constructors

Constructor and Description
OffHeapNamespaceExtractionCacheManager(com.metamx.common.lifecycle.Lifecycle lifecycle, ConcurrentMap<String,com.google.common.base.Function<String,String>> fnCache, com.metamx.emitter.service.ServiceEmitter emitter, Map<Class<? extends ExtractionNamespace>,ExtractionNamespaceFunctionFactory<?>> namespaceFunctionFactoryMap)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	delete(String namespaceKey) Clears out resources used by the namespace such as threads.
ConcurrentMap<String,String>	getCacheMap(String namespaceOrCacheKey) Return a ConcurrentMap with the specified ID (either namespace's name or a cache key ID)
protected boolean	swapAndClearCache(String namespaceKey, String cacheKey) This method is expected to swap the cacheKey into the active namespace, and leave future requests for new cacheKey available.

Methods inherited from class io.druid.server.namespace.cache.NamespaceExtractionCacheManager

getKnownNamespaces, getPostRunnable, getVersion, schedule, schedule, scheduleOrUpdate, waitForServiceToEnd

Methods inherited from class java.lang.Object

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

Constructor Detail

OffHeapNamespaceExtractionCacheManager

@Inject
public OffHeapNamespaceExtractionCacheManager(com.metamx.common.lifecycle.Lifecycle lifecycle,
                                             ConcurrentMap<String,com.google.common.base.Function<String,String>> fnCache,
                                             com.metamx.emitter.service.ServiceEmitter emitter,
                                             Map<Class<? extends ExtractionNamespace>,ExtractionNamespaceFunctionFactory<?>> namespaceFunctionFactoryMap)

Method Detail

swapAndClearCache

protected boolean swapAndClearCache(String namespaceKey,
                        String cacheKey)

Description copied from class: NamespaceExtractionCacheManager

This method is expected to swap the cacheKey into the active namespace, and leave future requests for new cacheKey available. getCacheMap(cacheKey) should return empty data after this call.

Specified by:

swapAndClearCache in class NamespaceExtractionCacheManager

Parameters:

namespaceKey - The namespace to swap the cache into

cacheKey - The cacheKey that contains the data of interest

Returns:

true if old data was cleared. False if no old data was found

delete

public boolean delete(String namespaceKey)

Description copied from class: NamespaceExtractionCacheManager

Clears out resources used by the namespace such as threads. Implementations may override this and call super.delete(...) if they have resources of their own which need cleared.

This particular method is NOT thread safe, and any impl which is intended to be thread safe should safe-guard calls to this method.

Overrides:

delete in class NamespaceExtractionCacheManager

Parameters:

namespaceKey - The namespace to be deleted

Returns:

True if a deletion occurred, false if no deletion occurred.

getCacheMap

public ConcurrentMap<String,String> getCacheMap(String namespaceOrCacheKey)

Description copied from class: NamespaceExtractionCacheManager

Return a ConcurrentMap with the specified ID (either namespace's name or a cache key ID)

Specified by:

getCacheMap in class NamespaceExtractionCacheManager

Parameters:

namespaceOrCacheKey - Either a namespace or cache key should be acceptable here.

Returns:

A ConcurrentMap that is backed by the impl which implements this method.