Modifier and Type | Method and Description |
---|---|
DruidQuery<?> |
ResponseException.getDruidQuery() |
Constructor and Description |
---|
ResponseException(int statusCode,
String reason,
String description,
DruidQuery<?> druidQuery)
Deprecated.
In order to ensure correct serialization of the Druid Query, an ObjectWriter with all appropriate
configuration should be passed in to the constructor
|
ResponseException(int statusCode,
String reason,
String description,
DruidQuery<?> druidQuery,
Throwable cause)
Deprecated.
In order to ensure correct serialization of the Druid Query, an ObjectWriter with all appropriate
configuration should be passed in to the constructor
|
ResponseException(int statusCode,
String reason,
String description,
DruidQuery<?> druidQuery,
Throwable cause,
com.fasterxml.jackson.databind.ObjectWriter objectWriter)
Class constructor with all the parameters to prepare the error response, plus a writer to serialize the Druid
query.
|
Modifier and Type | Method and Description |
---|---|
javax.ws.rs.core.Response |
HttpResponseMaker.buildErrorResponse(int statusCode,
String reason,
String description,
DruidQuery<?> druidQuery)
Prepare Response object from error details with reason and description.
|
Modifier and Type | Class and Description |
---|---|
class |
TemplateDruidQuery
Template Druid Query.
|
Modifier and Type | Method and Description |
---|---|
Future<org.asynchttpclient.Response> |
DruidWebService.postDruidQuery(RequestContext context,
SuccessCallback success,
HttpErrorCallback error,
FailureCallback failure,
DruidQuery<?> query)
Serializes the provided query and invokes POST on the druid broker.
|
Modifier and Type | Method and Description |
---|---|
Future<org.asynchttpclient.Response> |
AsyncDruidWebServiceImpl.postDruidQuery(RequestContext context,
SuccessCallback success,
HttpErrorCallback error,
FailureCallback failure,
DruidQuery<?> druidQuery) |
Modifier and Type | Method and Description |
---|---|
Optional<? extends DruidQuery<?>> |
DataSource.getQuery()
Get the query that defines the data source.
|
Modifier and Type | Interface and Description |
---|---|
interface |
DruidQuery<Q extends DruidQuery<? super Q>>
Common interface for Druid Query classes.
|
Modifier and Type | Interface and Description |
---|---|
interface |
DruidAggregationQuery<Q extends DruidAggregationQuery<? super Q>>
Common interface for Druid Query classes.
|
interface |
DruidFactQuery<Q extends DruidFactQuery<? super Q>>
Common interface for Druid Fact Query classes.
|
interface |
DruidMetadataQuery<Q extends DruidMetadataQuery<? super Q>>
Common interface for Druid Query classes.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractDruidAggregationQuery<Q extends AbstractDruidAggregationQuery<? super Q>>
Base class for druid aggregation queries.
|
class |
AbstractDruidFactQuery<Q extends AbstractDruidFactQuery<? super Q>>
Base class for druid aggregation queries.
|
class |
AbstractDruidQuery<Q extends AbstractDruidQuery<? super Q>>
Base class for druid queries.
|
class |
DruidSearchQuery
Class model for making Druid search queries.
|
class |
GroupByQuery
Druid groupBy query.
|
class |
LookbackQuery
Druid lookback query.
|
class |
SegmentMetadataQuery
Druid segment metadata query.
|
class |
TimeBoundaryQuery
Druid time boundary query.
|
class |
TimeSeriesQuery
Druid timeseries query.
|
class |
TopNQuery
Druid topN query.
|
class |
WeightEvaluationQuery
Query to generate weight to evaluate the query.
|
Modifier and Type | Method and Description |
---|---|
default DruidQuery<?> |
DruidQuery.getInnermostQuery()
If this structure is part of a query stack, return the lowest element.
|
Modifier and Type | Method and Description |
---|---|
default Optional<? extends DruidQuery> |
DruidQuery.getInnerQuery()
If this query is nestable, and has a nested query return it.
|
Modifier and Type | Method and Description |
---|---|
static <T> Optional<T> |
SerializerUtil.mapNearestDruidQuery(com.fasterxml.jackson.core.JsonGenerator gen,
Function<DruidQuery,T> mapper)
JSON tree walk to find the druid query context of the current context and apply handler to the DruidQuery,
finds the current context if current context is a druid query.
|
Modifier and Type | Class and Description |
---|---|
class |
SqlAggregationQuery
Wrapper around an
DruidAggregationQuery which always reports
itself as a DefaultQueryType.GROUP_BY . |
Modifier and Type | Method and Description |
---|---|
Future<com.fasterxml.jackson.databind.JsonNode> |
SqlBackedClient.executeQuery(DruidQuery<?> druidQuery,
SuccessCallback successCallback,
FailureCallback failureCallback)
Uses a
DruidQuery to fetch results from a Sql client,
parses the results from Sql and returns an equivalent JsonNode
to what druid would respond with. |
Future<com.fasterxml.jackson.databind.JsonNode> |
DefaultSqlBackedClient.executeQuery(DruidQuery<?> druidQuery,
SuccessCallback successCallback,
FailureCallback failureCallback) |
protected boolean |
DruidQueryToSqlConverter.isValidQuery(DruidQuery<?> druidQuery)
Determines whether or not a query is able to be processed using
the Sql backend.
|
Modifier and Type | Method and Description |
---|---|
static javax.ws.rs.core.Response |
RequestHandlerUtils.makeErrorResponse(int statusCode,
String reason,
String description,
DruidQuery<?> druidQuery,
com.fasterxml.jackson.databind.ObjectWriter writer)
Builds error response for Web Service.
|
static javax.ws.rs.core.Response |
RequestHandlerUtils.makeErrorResponse(javax.ws.rs.core.Response.StatusType status,
DruidQuery<?> druidQuery,
Throwable cause,
com.fasterxml.jackson.databind.ObjectWriter writer)
Builds error response from exception.
|
Copyright © 2016–2018 Yahoo! Inc.. All rights reserved.