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.