| 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 |
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 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 |
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) |
| 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. |
Copyright © 2011–2017. All rights reserved.