Modifier and Type | Class and Description |
---|---|
protected class |
LoadTask.TaskHttpErrorCallback
A basic nested class dealing with http errors that can be re-used by classes extending
LoadTask . |
Modifier and Type | Method and Description |
---|---|
protected HttpErrorCallback |
LoadTask.getErrorCallback()
Get a default callback for an http error.
|
Modifier and Type | Method and Description |
---|---|
void |
SqlDimensionValueLoader.setErrorCallback(HttpErrorCallback errorCallback) |
void |
DimensionValueLoader.setErrorCallback(HttpErrorCallback errorCallback)
Set a callback if an error occurs while querying.
|
void |
DruidDimensionValueLoader.setErrorCallback(HttpErrorCallback errorCallback) |
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 HttpErrorCallback |
DataSourceMetadataLoadTask.getErrorCallback(DataSourceName dataSourceName)
Get a default callback for an http error.
|
protected HttpErrorCallback |
DataSourceMetadataLoadTask.getErrorCallback(SingleDataSourcePhysicalTable table)
Deprecated.
Pass the DataSourceName directly, rather than via the PhysicalTable
|
Modifier and Type | Method and Description |
---|---|
HttpErrorCallback |
CacheV2ResponseProcessor.getErrorCallback(DruidAggregationQuery<?> druidQuery) |
HttpErrorCallback |
ResponseProcessor.getErrorCallback(DruidAggregationQuery<?> query)
Callback for handling http errors.
|
HttpErrorCallback |
ResultSetResponseProcessor.getErrorCallback(DruidAggregationQuery<?> druidQuery) |
HttpErrorCallback |
DruidPartialDataResponseProcessor.getErrorCallback(DruidAggregationQuery<?> druidQuery) |
HttpErrorCallback |
SplitQueryResponseProcessor.getErrorCallback(DruidAggregationQuery<?> druidQuery) |
HttpErrorCallback |
EtagCacheResponseProcessor.getErrorCallback(DruidAggregationQuery<?> druidQuery) |
HttpErrorCallback |
WeightCheckResponseProcessor.getErrorCallback(DruidAggregationQuery<?> druidQuery) |
HttpErrorCallback |
CachingResponseProcessor.getErrorCallback(DruidAggregationQuery<?> druidQuery) |
HttpErrorCallback |
MappingResponseProcessor.getStandardError(rx.subjects.Subject responseEmitter,
DruidAggregationQuery<?> druidQuery)
Get the standard error callback.
|
Copyright © 2016–2018 Yahoo! Inc.. All rights reserved.