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)
DataRequestHandler
handleRequest
in interface DataRequestHandler
context
- 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.