public interface DruidWebService
Modifier and Type | Method and Description |
---|---|
Future<org.asynchttpclient.Response> |
getJsonObject(SuccessCallback success,
HttpErrorCallback error,
FailureCallback failure,
String resourcePath)
Invokes GET on the druid broker with a callback expecting a JSON Object on success.
|
DruidServiceConfig |
getServiceConfig()
Returns the service configuration object for this web service.
|
Integer |
getTimeout()
Returns the timeout configured on this web service.
|
Future<org.asynchttpclient.Response> |
postDruidQuery(RequestContext context,
SuccessCallback success,
HttpErrorCallback error,
FailureCallback failure,
DruidQuery<?> query)
Serializes the provided query and invokes POST on the druid broker.
|
Future<org.asynchttpclient.Response> postDruidQuery(RequestContext context, SuccessCallback success, HttpErrorCallback error, FailureCallback failure, DruidQuery<?> query)
context
- The context for the Request.success
- callback for handling successful requests.error
- callback for handling http errors.failure
- callback for handling exception failures.query
- The druid query object to serialize.Future<org.asynchttpclient.Response> getJsonObject(SuccessCallback success, HttpErrorCallback error, FailureCallback failure, String resourcePath)
success
- callback for handling successful requests.error
- callback for handling http errors.failure
- callback for handling exception failures.resourcePath
- The url suffix for the remote resource. The prefix should be the shared Broker endpoint url.DruidServiceConfig getServiceConfig()
Integer getTimeout()
Copyright © 2016–2018 Yahoo! Inc.. All rights reserved.