Package | Description |
---|---|
com.yahoo.bard.webservice.web.responseprocessors |
Modifier and Type | Method and Description |
---|---|
void |
CacheV2ResponseProcessor.processResponse(com.fasterxml.jackson.databind.JsonNode json,
DruidAggregationQuery<?> druidQuery,
LoggingContext metadata) |
void |
ResponseProcessor.processResponse(com.fasterxml.jackson.databind.JsonNode json,
DruidAggregationQuery<?> query,
LoggingContext metadata)
Process the response json and respond to the original web request.
|
void |
ResultSetResponseProcessor.processResponse(com.fasterxml.jackson.databind.JsonNode json,
DruidAggregationQuery<?> druidQuery,
LoggingContext metadata) |
void |
DruidPartialDataResponseProcessor.processResponse(com.fasterxml.jackson.databind.JsonNode json,
DruidAggregationQuery<?> query,
LoggingContext metadata)
If status code is 200, do the following
Extract uncoveredIntervalsOverflowed from X-Druid-Response-Context inside the JsonNode passed into
DruidPartialDataResponseProcessor::processResponse, if it is true, invoke error response saying limit
overflowed,
Extract uncoveredIntervals from X-Druid-Response-Contex inside the JsonNode passed into
DruidPartialDataResponseProcessor::processResponse,
Parse both the uncoveredIntervals extracted above and allAvailableIntervals extracted from the union of
all the query's datasource's availabilities from DataSourceMetadataService into SimplifiedIntervalLists,
Compare both SimplifiedIntervalLists above, if allAvailableIntervals has any overlap with
uncoveredIntervals, invoke error response indicating druid is missing some data that are we are expecting
to exists.
|
void |
SplitQueryResponseProcessor.processResponse(com.fasterxml.jackson.databind.JsonNode json,
DruidAggregationQuery<?> druidQuery,
LoggingContext metadata) |
void |
EtagCacheResponseProcessor.processResponse(com.fasterxml.jackson.databind.JsonNode json,
DruidAggregationQuery<?> druidQuery,
LoggingContext metadata) |
void |
WeightCheckResponseProcessor.processResponse(com.fasterxml.jackson.databind.JsonNode json,
DruidAggregationQuery<?> druidQuery,
LoggingContext metadata) |
void |
CachingResponseProcessor.processResponse(com.fasterxml.jackson.databind.JsonNode json,
DruidAggregationQuery<?> druidQuery,
LoggingContext metadata) |
Copyright © 2016–2018 Yahoo! Inc.. All rights reserved.