io.druid.server.lookup.namespace

Class URIExtractionNamespaceCacheFactory

java.lang.Object

io.druid.server.lookup.namespace.URIExtractionNamespaceCacheFactory

All Implemented Interfaces:

ExtractionNamespaceCacheFactory<URIExtractionNamespace>

public final class URIExtractionNamespaceCacheFactory
extends Object
implements ExtractionNamespaceCacheFactory<URIExtractionNamespace>

Constructor Summary

Constructors

Constructor and Description
URIExtractionNamespaceCacheFactory(Map<String,SearchableVersionedDataFinder> pullers)

Method Summary

Modifier and Type

Method and Description

CacheScheduler.VersionedCache

populateCache(URIExtractionNamespace extractionNamespace, CacheScheduler.EntryImpl<URIExtractionNamespace> entryId, 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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

URIExtractionNamespaceCacheFactory

@Inject
public URIExtractionNamespaceCacheFactory(Map<String,SearchableVersionedDataFinder> pullers)

Method Detail

populateCache

@Nullable
public CacheScheduler.VersionedCache populateCache(URIExtractionNamespace extractionNamespace,
                                                             CacheScheduler.EntryImpl<URIExtractionNamespace> entryId,
                                                             @Nullable
                                                             String lastVersion,
                                                             CacheScheduler scheduler)
                                                      throws Exception

Description copied from interface: ExtractionNamespaceCacheFactory

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. If the lookup source is up-to-date, this methods returns null.

Specified by:

populateCache in interface ExtractionNamespaceCacheFactory<URIExtractionNamespace>

Parameters:

extractionNamespace - The ExtractionNamespace for which to populate data.

entryId - An object uniquely corresponding to the CacheScheduler.Entry, for which this populateCache() method is called. Also it has the same toString() representation, that is useful for logging

lastVersion - The version which was last cached

scheduler - Should be used only to call CacheScheduler.createVersionedCache(io.druid.server.lookup.namespace.cache.CacheScheduler.EntryImpl<? extends io.druid.query.lookup.namespace.ExtractionNamespace>, java.lang.String).

Returns:

the new cache along with the new version, or null if the last version is up-to-date.

Throws:

Exception