com.yahoo.bard.webservice.application

Class DruidDimensionValueLoader

java.lang.Object

com.yahoo.bard.webservice.application.DruidDimensionValueLoader

All Implemented Interfaces:

DimensionValueLoader

public class DruidDimensionValueLoader
extends Object
implements DimensionValueLoader

The DruidDimensionRowProvider sends requests to the druid search query interface to get a list of dimension values to add to the dimension cache.

Field Summary

Fields

Modifier and Type	Field and Description
static String	DRUID_DIM_LOADER_DIMENSIONS
static String	DRUID_DIM_LOADER_ROW_LIMIT

Fields inherited from interface com.yahoo.bard.webservice.application.DimensionValueLoader

LOG

Constructor Summary

Constructors

Constructor and Description
DruidDimensionValueLoader(PhysicalTableDictionary physicalTableDictionary, DimensionDictionary dimensionDictionary, DruidWebService druidWebService) DruidDimensionRowProvider fetches data from Druid and adds it to the dimension cache.
DruidDimensionValueLoader(PhysicalTableDictionary physicalTableDictionary, DimensionDictionary dimensionDictionary, List<String> dimensionsToLoad, DruidWebService druidWebService) DruidDimensionRowProvider fetches data from Druid and adds it to the dimension cache.

Method Summary

Modifier and Type	Method and Description
Set<DataSource>	getDataSources() Gets the list of datasources to query against.
Set<Dimension>	getDimensions() Gets the list of dimensions to load.
void	query(Dimension dimension, DataSource dataSource) Queries for a specific Dimension against the given DataSource.
void	setErrorCallback(HttpErrorCallback errorCallback) Set a callback if an error occurs while querying.
void	setFailureCallback(FailureCallback failureCallback) Set a callback if an exception occurs while querying.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.yahoo.bard.webservice.application.DimensionValueLoader

dimensionExistsInDataSource, load, queryDimension, updateDimension, updateDimensionWithValue

Field Detail

DRUID_DIM_LOADER_DIMENSIONS

public static final String DRUID_DIM_LOADER_DIMENSIONS

DRUID_DIM_LOADER_ROW_LIMIT

public static final String DRUID_DIM_LOADER_ROW_LIMIT

Constructor Detail

DruidDimensionValueLoader

public DruidDimensionValueLoader(PhysicalTableDictionary physicalTableDictionary,
                                 DimensionDictionary dimensionDictionary,
                                 DruidWebService druidWebService)

DruidDimensionRowProvider fetches data from Druid and adds it to the dimension cache. The dimensions loaded are taken from the system config.

Parameters:

physicalTableDictionary - The physical tables

dimensionDictionary - The dimensions to update

druidWebService - The druid webservice to query

DruidDimensionValueLoader

public DruidDimensionValueLoader(PhysicalTableDictionary physicalTableDictionary,
                                 DimensionDictionary dimensionDictionary,
                                 List<String> dimensionsToLoad,
                                 DruidWebService druidWebService)

DruidDimensionRowProvider fetches data from Druid and adds it to the dimension cache. The dimensions to be loaded can be passed in as a parameter.

Parameters:

physicalTableDictionary - The physical tables

dimensionDictionary - The dimension dictionary to load dimensions from.

dimensionsToLoad - The dimensions to use.

druidWebService - The druid webservice to query.

Method Detail

setErrorCallback

public void setErrorCallback(HttpErrorCallback errorCallback)

Description copied from interface: DimensionValueLoader

Set a callback if an error occurs while querying.

Specified by:

setErrorCallback in interface DimensionValueLoader

Parameters:

errorCallback - The callback to invoke on http errors.

setFailureCallback

public void setFailureCallback(FailureCallback failureCallback)

Description copied from interface: DimensionValueLoader

Set a callback if an exception occurs while querying.

Specified by:

setFailureCallback in interface DimensionValueLoader

Parameters:

failureCallback - The callback to invoke on exceptions.

getDimensions

public Set<Dimension> getDimensions()

Description copied from interface: DimensionValueLoader

Gets the list of dimensions to load.

Specified by:

getDimensions in interface DimensionValueLoader

Returns:

the list of dimensions.

getDataSources

public Set<DataSource> getDataSources()

Description copied from interface: DimensionValueLoader

Gets the list of datasources to query against.

Specified by:

getDataSources in interface DimensionValueLoader

Returns:

the list of datasources.

query

public void query(Dimension dimension,
                  DataSource dataSource)

Description copied from interface: DimensionValueLoader

Queries for a specific Dimension against the given DataSource.

Specified by:

query in interface DimensionValueLoader

Parameters:

dimension - The dimension to load.

dataSource - The datasource to query values for.