Uses of Class
io.druid.server.lookup.namespace.cache.CacheScheduler

Packages that use CacheScheduler

Package	Description
io.druid.query.lookup
io.druid.query.lookup.namespace
io.druid.server.lookup.namespace

Uses of CacheScheduler in io.druid.query.lookup

Constructors in io.druid.query.lookup with parameters of type CacheScheduler

Constructor and Description
NamespaceLookupExtractorFactory(ExtractionNamespace extractionNamespace, CacheScheduler cacheScheduler)
NamespaceLookupExtractorFactory(ExtractionNamespace extractionNamespace, long firstCacheTimeout, boolean injective, CacheScheduler cacheScheduler)

Uses of CacheScheduler in io.druid.query.lookup.namespace

Methods in io.druid.query.lookup.namespace with parameters of type CacheScheduler

Modifier and Type

Method and Description

CacheScheduler.VersionedCache

ExtractionNamespaceCacheFactory.populateCache(T namespace, CacheScheduler.EntryImpl<T> id, String lastVersion, CacheScheduler scheduler) If the lookup source, encapsulated by this ExtractionNamespaceCacheFactory, 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.

Uses of CacheScheduler in io.druid.server.lookup.namespace

Methods in io.druid.server.lookup.namespace with parameters of type CacheScheduler

Modifier and Type	Method and Description
CacheScheduler.VersionedCache	JDBCExtractionNamespaceCacheFactory.populateCache(JDBCExtractionNamespace namespace, CacheScheduler.EntryImpl<JDBCExtractionNamespace> entryId, String lastVersion, CacheScheduler scheduler)
CacheScheduler.VersionedCache	StaticMapExtractionNamespaceCacheFactory.populateCache(StaticMapExtractionNamespace namespace, CacheScheduler.EntryImpl<StaticMapExtractionNamespace> id, String lastVersion, CacheScheduler scheduler)
CacheScheduler.VersionedCache	URIExtractionNamespaceCacheFactory.populateCache(URIExtractionNamespace extractionNamespace, CacheScheduler.EntryImpl<URIExtractionNamespace> entryId, String lastVersion, CacheScheduler scheduler)