com.yahoo.bard.webservice.web.handlers

Class VolatileDataRequestHandler

java.lang.Object

com.yahoo.bard.webservice.web.handlers.VolatileDataRequestHandler

All Implemented Interfaces:

DataRequestHandler

public class VolatileDataRequestHandler
extends Object
implements DataRequestHandler

A request handler that loads the volatile intervals for a request into the response context.

Field Summary

Fields

Modifier and Type	Field and Description
protected DataRequestHandler	next
protected PhysicalTableDictionary	physicalTableDictionary
protected VolatileIntervalsService	volatileIntervalsService

Constructor Summary

Constructors

Constructor and Description
VolatileDataRequestHandler(DataRequestHandler next, PhysicalTableDictionary physicalTableDictionary, VolatileIntervalsService volatileIntervalsService) Detect volatile intervals and attach metadata describing the intervals to the request.

Method Summary

Modifier and Type	Method and Description
static SimplifiedIntervalList	getVolatileIntervalsWithDefault(Map<String,Serializable> context) Return the volatile intervals from the context.
boolean	handleRequest(RequestContext context, DataApiRequest request, DruidAggregationQuery<?> druidQuery, ResponseProcessor response) Handle the response, passing the request down the chain as necessary.

Methods inherited from class java.lang.Object

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

Field Detail

next

@NotNull
protected final DataRequestHandler next

physicalTableDictionary

@NotNull
protected final PhysicalTableDictionary physicalTableDictionary

volatileIntervalsService

@NotNull
protected final VolatileIntervalsService volatileIntervalsService

Constructor Detail

VolatileDataRequestHandler

public VolatileDataRequestHandler(DataRequestHandler next,
                                  PhysicalTableDictionary physicalTableDictionary,
                                  VolatileIntervalsService volatileIntervalsService)

Detect volatile intervals and attach metadata describing the intervals to the request.

Parameters:

next - The next Request handler to call

physicalTableDictionary - the repository of slice data

volatileIntervalsService - a provider for volatile intervals (per physical table)

Method Detail

handleRequest

public boolean handleRequest(RequestContext context,
                             DataApiRequest request,
                             DruidAggregationQuery<?> druidQuery,
                             ResponseProcessor response)

Description copied from interface: DataRequestHandler

Handle the response, passing the request down the chain as necessary.

Specified by:

handleRequest in interface DataRequestHandler

Parameters:

context - The context for the Request

request - The Api Request Object

druidQuery - The druid query

response - The Async response

Returns:

True if the async response has been processed or passed to a future for processing

getVolatileIntervalsWithDefault

public static SimplifiedIntervalList getVolatileIntervalsWithDefault(Map<String,Serializable> context)

Return the volatile intervals from the context.

Parameters:

context - The RequestContext object containing the volatile intervals if any

Returns:

the volatile intervals from the request or an empty list