com.yahoo.bard.webservice.metadata

Class RegisteredLookupMetadataLoadTask

java.lang.Object

com.yahoo.bard.webservice.application.LoadTask<Boolean>

com.yahoo.bard.webservice.metadata.RegisteredLookupMetadataLoadTask

All Implemented Interfaces:

Runnable

public class RegisteredLookupMetadataLoadTask
extends LoadTask<Boolean>

Lookup Load task sends requests to Druid coordinator and returns load statuses of lookup metadata in Druid.

Nested Class Summary

Nested classes/interfaces inherited from class com.yahoo.bard.webservice.application.LoadTask

LoadTask.TaskFailureCallback, LoadTask.TaskHttpErrorCallback

Field Summary

Fields inherited from class com.yahoo.bard.webservice.application.LoadTask

delay, future, isPeriodic, loaderName, period

Constructor Summary

Constructors

Constructor and Description
RegisteredLookupMetadataLoadTask(DruidWebService druidClient, DimensionDictionary dimensionDictionary) Constructor.

Method Summary

Modifier and Type	Method and Description
protected SuccessCallback	buildLookupSuccessCallback() Returns a callback that has actions on lookup metadata from a successful Druid response.
Set<String>	getLookupTiers() Returns a list of configured lookup tiers.
Set<String>	getPendingLookups() Returns a set of lookup namespaces that have not been loaded to Druid yet.
void	run()
void	setLookupTiers(Set<String> lookupTiers) Updates list of configured lookup tiers.

Methods inherited from class com.yahoo.bard.webservice.application.LoadTask

getDefinedDelay, getDefinedPeriod, getErrorCallback, getFailureCallback, getFuture, getName, isPeriodic, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

RegisteredLookupMetadataLoadTask

public RegisteredLookupMetadataLoadTask(DruidWebService druidClient,
                                        DimensionDictionary dimensionDictionary)

Constructor.

Parameters:

druidClient - The client to query Druid coordinator

dimensionDictionary - A DimensionDictionary that is used to obtain a list of lookups in Fili.

Method Detail

run

public void run()

Specified by:

run in interface Runnable

Specified by:

run in class LoadTask<Boolean>

getLookupTiers

public Set<String> getLookupTiers()

Returns a list of configured lookup tiers.

See http://druid.io/docs/latest/querying/lookups.html for details on "tier".

Returns:

the list of configured lookup tiers

setLookupTiers

public void setLookupTiers(Set<String> lookupTiers)

Updates list of configured lookup tiers.

This method becomes useful when a new look up tier is added at runtime.

Parameters:

lookupTiers - A new list of configured lookup tiers

getPendingLookups

public Set<String> getPendingLookups()

Returns a set of lookup namespaces that have not been loaded to Druid yet.

Returns:

the set of lookup namespaces that have not been loaded to Druid yet

buildLookupSuccessCallback

protected SuccessCallback buildLookupSuccessCallback()

Returns a callback that has actions on lookup metadata from a successful Druid response.

The callback obtains a complete list of configured lookups from Druid coordinator, compares this list against the list of lookups configured in Fili, and finds all lookup namespace names that are either not loaded yet in Druid or does not exist in Druid at all. These namespaces can be retrieved later by calling getPendingLookups().

Returns:

the callback that has actions on lookups from a successful Druid response