Package | Description |
---|---|
io.druid.query.lookup | |
io.druid.query.lookup.namespace | |
io.druid.server.lookup.namespace |
Constructor and Description |
---|
NamespaceLookupExtractorFactory(ExtractionNamespace extractionNamespace,
CacheScheduler cacheScheduler) |
NamespaceLookupExtractorFactory(ExtractionNamespace extractionNamespace,
long firstCacheTimeout,
boolean injective,
CacheScheduler cacheScheduler) |
Modifier and Type | Method and Description |
---|---|
CacheScheduler.VersionedCache |
CacheGenerator.generateCache(T namespace,
CacheScheduler.EntryImpl<T> id,
String lastVersion,
CacheScheduler scheduler)
If the lookup source, encapsulated by this
CacheGenerator , has data newer than identified
by the given lastVersion (which is null at the first run of this method, or the version from the previous
run), this method creates a new CacheScheduler.VersionedCache with createVersionedCache(io.druid.server.lookup.namespace.cache.CacheScheduler.EntryImpl<? extends io.druid.query.lookup.namespace.ExtractionNamespace>, java.lang.String) , called on the given scheduler , with the version string identifying
the current version of lookup source, populates the created VersionedCache and returns it. |
Modifier and Type | Method and Description |
---|---|
CacheScheduler.VersionedCache |
JdbcCacheGenerator.generateCache(JdbcExtractionNamespace namespace,
CacheScheduler.EntryImpl<JdbcExtractionNamespace> entryId,
String lastVersion,
CacheScheduler scheduler) |
CacheScheduler.VersionedCache |
StaticMapCacheGenerator.generateCache(StaticMapExtractionNamespace namespace,
CacheScheduler.EntryImpl<StaticMapExtractionNamespace> id,
String lastVersion,
CacheScheduler scheduler) |
CacheScheduler.VersionedCache |
UriCacheGenerator.generateCache(UriExtractionNamespace extractionNamespace,
CacheScheduler.EntryImpl<UriExtractionNamespace> entryId,
String lastVersion,
CacheScheduler scheduler) |
Copyright © 2011–2018. All rights reserved.