Package | Description |
---|---|
io.druid.query.lookup.namespace | |
io.druid.server.lookup.namespace | |
io.druid.server.lookup.namespace.cache |
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 CacheScheduler.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) |
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. |
Copyright © 2011–2018. All rights reserved.