Package | Description |
---|---|
io.druid.query.lookup | |
io.druid.query.lookup.namespace | |
io.druid.server.lookup.namespace | |
io.druid.server.lookup.namespace.cache |
Modifier and Type | Method and Description |
---|---|
ExtractionNamespace |
NamespaceLookupExtractorFactory.getExtractionNamespace() |
Constructor and Description |
---|
NamespaceLookupExtractorFactory(ExtractionNamespace extractionNamespace,
CacheScheduler cacheScheduler) |
NamespaceLookupExtractorFactory(ExtractionNamespace extractionNamespace,
long firstCacheTimeout,
boolean injective,
CacheScheduler cacheScheduler) |
Modifier and Type | Interface and Description |
---|---|
interface |
ExtractionNamespaceCacheFactory<T extends ExtractionNamespace> |
Modifier and Type | Class and Description |
---|---|
class |
JDBCExtractionNamespace |
class |
StaticMapExtractionNamespace
This class is intended to be used in general cluster testing, and not as a serious lookup.
|
class |
URIExtractionNamespace |
Modifier and Type | Method and Description |
---|---|
static com.google.inject.multibindings.MapBinder<Class<? extends ExtractionNamespace>,ExtractionNamespaceCacheFactory<?>> |
NamespaceExtractionModule.getNamespaceFactoryMapBinder(com.google.inject.Binder binder) |
Modifier and Type | Class and Description |
---|---|
class |
CacheScheduler.Entry<T extends ExtractionNamespace> |
class |
CacheScheduler.EntryImpl<T extends ExtractionNamespace>
This class effectively contains the whole state and most of the logic of
CacheScheduler.Entry , need to be a separate class
because the Entry must not be referenced from the runnable executed in CacheScheduler.cacheManager 's ExecutorService,
that would be a leak preventing the Entry to be collected by GC, and therefore CacheScheduler.EntryImpl.entryCleaner to be run by
the JVM. |
Modifier and Type | Method and Description |
---|---|
<T extends ExtractionNamespace> |
CacheScheduler.schedule(T namespace) |
Modifier and Type | Method and Description |
---|---|
CacheScheduler.Entry |
CacheScheduler.scheduleAndWait(ExtractionNamespace namespace,
long waitForFirstRunMs) |
Modifier and Type | Method and Description |
---|---|
CacheScheduler.VersionedCache |
CacheScheduler.createVersionedCache(CacheScheduler.EntryImpl<? extends ExtractionNamespace> entryId,
String version)
This method should be used from
ExtractionNamespaceCacheFactory.populateCache(T, io.druid.server.lookup.namespace.cache.CacheScheduler.EntryImpl<T>, java.lang.String, io.druid.server.lookup.namespace.cache.CacheScheduler) implementations, to obtain
a CacheScheduler.VersionedCache to be returned. |
Constructor and Description |
---|
CacheScheduler(com.metamx.emitter.service.ServiceEmitter serviceEmitter,
Map<Class<? extends ExtractionNamespace>,ExtractionNamespaceCacheFactory<?>> namespacePopulatorMap,
NamespaceExtractionCacheManager cacheManager) |
Copyright © 2011–2017. All rights reserved.