Modifier and Type | Method and Description |
---|---|
DruidAggregationQuery<?> |
DruidQueryBuilder.buildQuery(DataApiRequest request,
TemplateDruidQuery template)
Build a druid query object from an API request and it's templateDruidQuery.
|
protected boolean |
DruidQueryBuilder.canOptimizeTimeSeries(DataApiRequest apiRequest,
TemplateDruidQuery templateDruidQuery)
Determine if the optimization to a Timeseries query can be done.
|
protected boolean |
DruidQueryBuilder.canOptimizeTopN(DataApiRequest apiRequest,
TemplateDruidQuery templateDruidQuery)
Determine if the optimization to a TopN query can be done.
|
Modifier and Type | Method and Description |
---|---|
TemplateDruidQuery |
TemplateDruidQueryMerger.merge(DataApiRequest request)
Merge all of the TemplateDruidQueries from all of the Metrics in an DataApiRequest together.
|
Modifier and Type | Method and Description |
---|---|
static TableIdentifier |
TableIdentifier.create(DataApiRequest request)
Builder.
|
Modifier and Type | Method and Description |
---|---|
Granularity |
RequestQueryGranularityResolver.apply(DataApiRequest request,
TemplateDruidQuery templateDruidQuery) |
Granularity |
RequestQueryGranularityResolver.resolveAcceptingGrain(DataApiRequest apiRequest,
TemplateDruidQuery query)
Get the a granularity which must be satisfied by any answering table granularity for this request.
|
Constructor and Description |
---|
DataSourceConstraint(DataApiRequest dataApiRequest,
DruidAggregationQuery<?> templateDruidQuery)
Constructor.
|
QueryPlanningConstraint(DataApiRequest dataApiRequest,
TemplateDruidQuery templateDruidQuery)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
static Set<String> |
TableUtils.getColumnNames(DataApiRequest request,
DruidAggregationQuery<?> query)
Get the schema column names from the dimensions and metrics.
|
static Set<String> |
TableUtils.getColumnNames(DataApiRequest request,
DruidAggregationQuery<?> query,
PhysicalTable table)
Deprecated.
in favor of getColumnNames(DataApiRequest, DruidAggregationQuery) returning dimension api name
|
static Stream<Dimension> |
TableUtils.getDimensions(DataApiRequest request,
DruidAggregationQuery<?> query)
Get a stream returning all the fact store dimensions.
|
Modifier and Type | Method and Description |
---|---|
Set<FilteredAggregation> |
FilteredSketchMetricsHelper.getFilteredAggregation(com.fasterxml.jackson.databind.JsonNode filter,
Aggregation aggregation,
DimensionDictionary dimensionDictionary,
LogicalTable table,
DataApiRequest apiRequest)
Deprecated.
|
Set<FilteredAggregation> |
MetricsFilterSetBuilder.getFilteredAggregation(com.fasterxml.jackson.databind.JsonNode filter,
Aggregation aggregation,
DimensionDictionary dimensionDictionary,
LogicalTable table,
DataApiRequest apiRequest)
For a given aggregator, this method applies the filter and returns a set of filtered aggregations.
|
Set<FilteredAggregation> |
FilteredThetaSketchMetricsHelper.getFilteredAggregation(com.fasterxml.jackson.databind.JsonNode filter,
Aggregation aggregation,
DimensionDictionary dimensionDictionary,
LogicalTable table,
DataApiRequest apiRequest) |
LogicalMetric |
FilteredSketchMetricsHelper.getFilteredLogicalMetric(LogicalMetric logicalMetric,
com.fasterxml.jackson.databind.JsonNode metricFilterObject,
DimensionDictionary dimensionDictionary,
LogicalTable table,
DataApiRequest apiRequest)
Deprecated.
|
LogicalMetric |
MetricsFilterSetBuilder.getFilteredLogicalMetric(LogicalMetric logicalMetric,
com.fasterxml.jackson.databind.JsonNode metricFilterObject,
DimensionDictionary dimensionDictionary,
LogicalTable table,
DataApiRequest apiRequest)
Provides filter wrapped logical metric for the given logical metric.
|
LogicalMetric |
FilteredThetaSketchMetricsHelper.getFilteredLogicalMetric(LogicalMetric logicalMetric,
com.fasterxml.jackson.databind.JsonNode metricFilterObject,
DimensionDictionary dimensionDictionary,
LogicalTable table,
DataApiRequest apiRequest) |
TemplateDruidQuery |
FilteredSketchMetricsHelper.updateTemplateDruidQuery(TemplateDruidQuery query,
com.fasterxml.jackson.databind.JsonNode metricFilterObject,
DimensionDictionary dimensionDictionary,
LogicalTable table,
DataApiRequest apiRequest)
Deprecated.
|
TemplateDruidQuery |
MetricsFilterSetBuilder.updateTemplateDruidQuery(TemplateDruidQuery query,
com.fasterxml.jackson.databind.JsonNode metricFilterObject,
DimensionDictionary dimensionDictionary,
LogicalTable table,
DataApiRequest apiRequest)
Method to update a given query by changing aggregators to filteredAggregators and updating postAggs to reference
the filteredAggregators.
|
TemplateDruidQuery |
FilteredThetaSketchMetricsHelper.updateTemplateDruidQuery(TemplateDruidQuery query,
com.fasterxml.jackson.databind.JsonNode metricFilterObject,
DimensionDictionary dimensionDictionary,
LogicalTable table,
DataApiRequest apiRequest) |
Constructor and Description |
---|
ResponseData(ResultSet resultSet,
DataApiRequest apiRequest,
SimplifiedIntervalList missingIntervals,
SimplifiedIntervalList volatileIntervals,
Pagination pagination,
Map<String,URI> paginationLinks)
Deprecated.
All the values needed to build a Response should be passed explicitly instead of relying on the
DataApiRequest
|
Modifier and Type | Class and Description |
---|---|
class |
DataApiRequestImpl
Data API Request Implementation binds, validates, and models the parts of a request to the data endpoint.
|
Modifier and Type | Method and Description |
---|---|
DataApiRequest |
DataApiRequestFactory.buildApiRequest(String tableName,
String granularity,
List<javax.ws.rs.core.PathSegment> dimensions,
String logicalMetrics,
String intervals,
String apiFilters,
String havings,
String sorts,
String count,
String topN,
String format,
String timeZoneId,
String asyncAfter,
String perPage,
String page,
javax.ws.rs.core.UriInfo uriInfo,
BardConfigResources bardConfigResources)
Factory method for building
DataApiRequest objects. |
DataApiRequest |
DefaultDataApiRequestFactory.buildApiRequest(String tableName,
String granularity,
List<javax.ws.rs.core.PathSegment> dimensions,
String logicalMetrics,
String intervals,
String apiFilters,
String havings,
String sorts,
String count,
String topN,
String format,
String timeZoneId,
String asyncAfter,
String perPage,
String page,
javax.ws.rs.core.UriInfo uriInfo,
BardConfigResources bardConfigResources) |
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) |
WebServiceHandler |
WebServiceHandlerSelector.select(DruidAggregationQuery<?> druidQuery,
DataApiRequest request,
RequestContext context)
Select which web service to use, based on the request information.
|
WebServiceHandler |
DefaultWebServiceHandlerSelector.select(DruidAggregationQuery<?> druidQuery,
DataApiRequest request,
RequestContext context) |
Modifier and Type | Field and Description |
---|---|
protected DataApiRequest |
MappingResponseProcessor.apiRequest |
Modifier and Type | Method and Description |
---|---|
DataApiRequest |
MappingResponseProcessor.getDataApiRequest() |
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) |
protected List<ResultSetMapper> |
MappingResponseProcessor.buildResultSetMapperList(DataApiRequest apiRequest)
Extract all ResultSetMappers from the api request.
|
Constructor and Description |
---|
MappingResponseProcessor(DataApiRequest apiRequest,
ObjectMappersSuite objectMappers)
Constructor.
|
ResultSetResponseProcessor(DataApiRequest apiRequest,
rx.subjects.Subject<PreResponse,PreResponse> responseEmitter,
DruidResponseParser druidResponseParser,
ObjectMappersSuite objectMappers,
HttpResponseMaker httpResponseMaker)
Constructor.
|
SplitQueryResponseProcessor(ResponseProcessor next,
DataApiRequest request,
DruidAggregationQuery<?> druidQuery,
Map<org.joda.time.Interval,AtomicInteger> expectedIntervals,
RequestLog logCtx)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
protected DataApiRequest |
RoleDimensionApiFilterRequestMapper.internalApply(DataApiRequest request,
javax.ws.rs.container.ContainerRequestContext context) |
Modifier and Type | Method and Description |
---|---|
protected DataApiRequest |
RoleDimensionApiFilterRequestMapper.internalApply(DataApiRequest request,
javax.ws.rs.container.ContainerRequestContext context) |
Constructor and Description |
---|
RoleDimensionApiFilterRequestMapper(ResourceDictionaries resourceDictionaries,
Dimension dimension,
Map<String,Set<ApiFilter>> roleApiFilters,
RequestMapper<DataApiRequest> next)
Constructor.
|
Copyright © 2016–2018 Yahoo! Inc.. All rights reserved.