| 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  | 
CacheGenerator<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>,CacheGenerator<?>> | 
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  
CacheGenerator.generateCache(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(ServiceEmitter serviceEmitter,
              Map<Class<? extends ExtractionNamespace>,CacheGenerator<?>> namespaceGeneratorMap,
              NamespaceExtractionCacheManager cacheManager)  | 
Copyright © 2011–2018. All rights reserved.