Modifier and Type | Method and Description |
---|---|
Future<org.asynchttpclient.Response> |
DruidWebService.getJsonObject(SuccessCallback success,
HttpErrorCallback error,
FailureCallback failure,
String resourcePath)
Invokes GET on the druid broker with a callback expecting a JSON Object on success.
|
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.getJsonObject(SuccessCallback success,
HttpErrorCallback error,
FailureCallback failure,
String resourcePath) |
Future<org.asynchttpclient.Response> |
AsyncDruidWebServiceImpl.postDruidQuery(RequestContext context,
SuccessCallback success,
HttpErrorCallback error,
FailureCallback failure,
DruidQuery<?> druidQuery) |
protected Future<org.asynchttpclient.Response> |
AsyncDruidWebServiceImpl.sendRequest(SuccessCallback success,
HttpErrorCallback error,
FailureCallback failure,
org.asynchttpclient.BoundRequestBuilder requestBuilder,
String timerName,
AtomicLong outstanding)
Serializes the provided query and invokes a request on the druid broker.
|
Modifier and Type | Method and Description |
---|---|
protected SuccessCallback |
DataSourceMetadataLoadTask.buildDataSourceMetadataSuccessCallback(DataSourceName dataSourceName)
Callback to parse druid datasource metadata response.
|
protected SuccessCallback |
DataSourceMetadataLoadTask.buildDataSourceMetadataSuccessCallback(SingleDataSourcePhysicalTable table)
Deprecated.
Pass the DataSourceName directly, rather than via the PhysicalTable
|
protected SuccessCallback |
RegisteredLookupMetadataLoadTask.buildLookupSuccessCallback()
Returns a callback that has actions on lookup metadata from a successful Druid response.
|
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) |
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.
|
Copyright © 2016–2018 Yahoo! Inc.. All rights reserved.