Modifier and Type | Class and Description |
---|---|
protected class |
LoadTask.TaskFailureCallback
A basic nested class dealing with failures that can be re-used by classes extending
LoadTask . |
Modifier and Type | Method and Description |
---|---|
protected FailureCallback |
LoadTask.getFailureCallback()
Get a default callback to use when a failure occurs.
|
Modifier and Type | Method and Description |
---|---|
void |
SqlDimensionValueLoader.setFailureCallback(FailureCallback failureCallback) |
void |
DimensionValueLoader.setFailureCallback(FailureCallback failureCallback)
Set a callback if an exception occurs while querying.
|
void |
DruidDimensionValueLoader.setFailureCallback(FailureCallback failureCallback) |
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 |
---|---|
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 |
---|---|
FailureCallback |
CacheV2ResponseProcessor.getFailureCallback(DruidAggregationQuery<?> druidQuery) |
FailureCallback |
ResponseProcessor.getFailureCallback(DruidAggregationQuery<?> query)
Callback handler for unexpected failures.
|
FailureCallback |
ResultSetResponseProcessor.getFailureCallback(DruidAggregationQuery<?> druidQuery) |
FailureCallback |
DruidPartialDataResponseProcessor.getFailureCallback(DruidAggregationQuery<?> druidQuery) |
FailureCallback |
SplitQueryResponseProcessor.getFailureCallback(DruidAggregationQuery<?> druidQuery) |
FailureCallback |
EtagCacheResponseProcessor.getFailureCallback(DruidAggregationQuery<?> druidQuery) |
FailureCallback |
WeightCheckResponseProcessor.getFailureCallback(DruidAggregationQuery<?> druidQuery) |
FailureCallback |
CachingResponseProcessor.getFailureCallback(DruidAggregationQuery<?> druidQuery) |
FailureCallback |
MappingResponseProcessor.getStandardFailure(rx.subjects.Subject responseEmitter,
DruidAggregationQuery<?> druidQuery)
Get the standard failure callback.
|
Copyright © 2016–2018 Yahoo! Inc.. All rights reserved.