public class PartialDataRequestHandler extends Object implements DataRequestHandler
Partial data request handler puts a list of all missing intervals for a group by into the context and injects a mapper into the response processor
| Modifier and Type | Field and Description |
|---|---|
protected DataRequestHandler |
next |
static String |
PARTIAL_DATA_HEADER |
protected PartialDataHandler |
partialDataHandler |
| Constructor and Description |
|---|
PartialDataRequestHandler(DataRequestHandler next,
PartialDataHandler partialDataHandler)
Wrap the response processor in a partial data check.
|
PartialDataRequestHandler(DataRequestHandler next,
PhysicalTableDictionary physicalTableDictionary,
PartialDataHandler partialDataHandler)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
static SimplifiedIntervalList |
getPartialIntervalsWithDefault(Map<String,Serializable> context)
Return the missing 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.
|
public static final String PARTIAL_DATA_HEADER
@NotNull protected final DataRequestHandler next
@NotNull protected final PartialDataHandler partialDataHandler
@Deprecated public PartialDataRequestHandler(DataRequestHandler next, PhysicalTableDictionary physicalTableDictionary, PartialDataHandler partialDataHandler)
PartialDataRequestHandler(DataRequestHandler, PartialDataHandler)next - The next request handler to invokephysicalTableDictionary - the repository of slice datapartialDataHandler - the service to calculate partial data from table availabilitiespublic PartialDataRequestHandler(DataRequestHandler next, PartialDataHandler partialDataHandler)
next - The next request handler to invokepartialDataHandler - the service to calculate partial data from table availabilitiespublic boolean handleRequest(RequestContext context, DataApiRequest request, DruidAggregationQuery<?> druidQuery, ResponseProcessor response)
DataRequestHandlerhandleRequest in interface DataRequestHandlercontext - The context for the Requestrequest - The Api Request ObjectdruidQuery - The druid queryresponse - The Async responsepublic static SimplifiedIntervalList getPartialIntervalsWithDefault(Map<String,Serializable> context)
WARNING: A serialization issue may result in the context value being a list but not a Simplified Interval List. See https://github.com/yahoo/fili/issues/657
context - The map containing the missing intervals if anyCopyright © 2016–2018 Yahoo! Inc.. All rights reserved.