Package | Description |
---|---|
com.yahoo.bard.webservice.web.handlers | |
com.yahoo.bard.webservice.web.responseprocessors |
Modifier and Type | Method and Description |
---|---|
protected SuccessCallback |
WeightCheckRequestHandler.buildSuccessCallback(RequestContext context,
DataApiRequest request,
DruidAggregationQuery<?> druidQuery,
ResponseProcessor response,
long queryRowLimit)
Build a callback which continues the original request or refuses it with an HTTP INSUFFICIENT_STORAGE (507)
status based on the cardinality of the requester 's query as measured by the weight check query.
|
boolean |
SqlRequestHandler.handleRequest(RequestContext context,
DataApiRequest request,
DruidAggregationQuery<?> druidQuery,
ResponseProcessor response)
Handles a request by detecting if it's a sql backed table and sending to a sql backend.
|
boolean |
TopNMapperRequestHandler.handleRequest(RequestContext context,
DataApiRequest request,
DruidAggregationQuery<?> druidQuery,
ResponseProcessor response) |
boolean |
WeightCheckRequestHandler.handleRequest(RequestContext context,
DataApiRequest request,
DruidAggregationQuery<?> druidQuery,
ResponseProcessor response) |
boolean |
PaginationRequestHandler.handleRequest(RequestContext context,
DataApiRequest request,
DruidAggregationQuery<?> druidQuery,
ResponseProcessor response) |
boolean |
AsyncWebServiceRequestHandler.handleRequest(RequestContext context,
DataApiRequest request,
DruidAggregationQuery<?> druidQuery,
ResponseProcessor response) |
boolean |
SplitQueryRequestHandler.handleRequest(RequestContext context,
DataApiRequest request,
DruidAggregationQuery<?> druidQuery,
ResponseProcessor response) |
boolean |
EtagCacheRequestHandler.handleRequest(RequestContext context,
DataApiRequest request,
DruidAggregationQuery<?> druidQuery,
ResponseProcessor response) |
boolean |
WebServiceHandler.handleRequest(RequestContext context,
DataApiRequest request,
DruidAggregationQuery<?> druidQuery,
ResponseProcessor response) |
boolean |
WebServiceSelectorRequestHandler.handleRequest(RequestContext context,
DataApiRequest request,
DruidAggregationQuery<?> druidQuery,
ResponseProcessor response) |
boolean |
VolatileDataRequestHandler.handleRequest(RequestContext context,
DataApiRequest request,
DruidAggregationQuery<?> druidQuery,
ResponseProcessor response) |
boolean |
CacheV2RequestHandler.handleRequest(RequestContext context,
DataApiRequest request,
DruidAggregationQuery<?> druidQuery,
ResponseProcessor response) |
boolean |
DataRequestHandler.handleRequest(RequestContext context,
DataApiRequest request,
DruidAggregationQuery<?> druidQuery,
ResponseProcessor response)
Handle the response, passing the request down the chain as necessary.
|
boolean |
CacheRequestHandler.handleRequest(RequestContext context,
DataApiRequest request,
DruidAggregationQuery<?> druidQuery,
ResponseProcessor response) |
boolean |
DruidPartialDataRequestHandler.handleRequest(RequestContext context,
DataApiRequest request,
DruidAggregationQuery<?> druidQuery,
ResponseProcessor response) |
boolean |
PartialDataRequestHandler.handleRequest(RequestContext context,
DataApiRequest request,
DruidAggregationQuery<?> druidQuery,
ResponseProcessor response) |
boolean |
DebugRequestHandler.handleRequest(RequestContext context,
DataApiRequest request,
DruidAggregationQuery<?> druidQuery,
ResponseProcessor response) |
boolean |
DateTimeSortRequestHandler.handleRequest(RequestContext context,
DataApiRequest request,
DruidAggregationQuery<?> druidQuery,
ResponseProcessor response) |
Modifier and Type | Interface and Description |
---|---|
interface |
FullResponseProcessor
Response processor for that extracts header information from Druid response and put the information in our own
response.
|
Modifier and Type | Class and Description |
---|---|
class |
CacheV2ResponseProcessor
A response processor which caches the results if appropriate after completing a query.
|
class |
CachingResponseProcessor
A response processor which caches the results if appropriate after completing a query.
|
class |
DruidPartialDataResponseProcessor
Response processor for finding missing partial data in Druid
|
class |
EtagCacheResponseProcessor
A response processor which caches the results if appropriate after completing a query according to etag value.
|
class |
MappingResponseProcessor
Response Processor which will perform result set mapping.
|
class |
ResultSetResponseProcessor
Callback handler for JSON to be processed into result sets.
|
class |
SplitQueryResponseProcessor
This response processor receives a list of expected intervals.
|
class |
WeightCheckResponseProcessor
A response processor which wraps a timer around the outer most response processor only in the event of an error
response.
|
Modifier and Type | Method and Description |
---|---|
ResponseProcessor |
ResponseProcessorFactory.build(DataApiRequest apiRequest,
rx.subjects.Subject<PreResponse,PreResponse> responseEmitter,
DruidResponseParser druidResponseParser,
ObjectMappersSuite objectMappers,
HttpResponseMaker httpResponseMaker)
Constructs a custom ResponseProcessor.
|
ResponseProcessor |
ResultSetResponseProcessorFactory.build(DataApiRequest apiRequest,
rx.subjects.Subject<PreResponse,PreResponse> responseEmitter,
DruidResponseParser druidResponseParser,
ObjectMappersSuite objectMappers,
HttpResponseMaker httpResponseMaker) |
Constructor and Description |
---|
CacheV2ResponseProcessor(ResponseProcessor next,
String cacheKey,
TupleDataCache<String,Long,String> dataCache,
QuerySigningService<Long> querySigningService,
com.fasterxml.jackson.databind.ObjectMapper mapper)
Constructor.
|
CachingResponseProcessor(ResponseProcessor next,
String cacheKey,
DataCache<String> dataCache,
com.fasterxml.jackson.databind.ObjectMapper mapper)
Constructor.
|
DruidPartialDataResponseProcessor(ResponseProcessor next)
Constructor.
|
EtagCacheResponseProcessor(ResponseProcessor next,
String cacheKey,
TupleDataCache<String,String,String> dataCache,
com.fasterxml.jackson.databind.ObjectMapper mapper)
Constructor.
|
SplitQueryResponseProcessor(ResponseProcessor next,
DataApiRequest request,
DruidAggregationQuery<?> druidQuery,
Map<org.joda.time.Interval,AtomicInteger> expectedIntervals,
RequestLog logCtx)
Constructor.
|
WeightCheckResponseProcessor(ResponseProcessor next)
Constructor.
|
Copyright © 2016–2018 Yahoo! Inc.. All rights reserved.