com.yahoo.bard.webservice.web.responseprocessors

Interface ResponseProcessor

All Known Subinterfaces:

FullResponseProcessor

All Known Implementing Classes:

CacheV2ResponseProcessor, CachingResponseProcessor, DruidPartialDataResponseProcessor, EtagCacheResponseProcessor, MappingResponseProcessor, ResultSetResponseProcessor, SplitQueryResponseProcessor, WeightCheckResponseProcessor

public interface ResponseProcessor

Response processing can result in failure or error or on success will receive a JSON document representing the result set for the query.

Method Summary

Modifier and Type	Method and Description
HttpErrorCallback	getErrorCallback(DruidAggregationQuery<?> query) Callback for handling http errors.
FailureCallback	getFailureCallback(DruidAggregationQuery<?> query) Callback handler for unexpected failures.
ResponseContext	getResponseContext() The response context allows state to be injected from construction and visible across response processor layers as necessary.
void	processResponse(com.fasterxml.jackson.databind.JsonNode json, DruidAggregationQuery<?> query, LoggingContext metadata) Process the response json and respond to the original web request.

Method Detail

getResponseContext

ResponseContext getResponseContext()

The response context allows state to be injected from construction and visible across response processor layers as necessary.

Returns:

The context data

getFailureCallback

FailureCallback getFailureCallback(DruidAggregationQuery<?> query)

Callback handler for unexpected failures.

Parameters:

query - The query associated with this failure

Returns:

The callback handler

getErrorCallback

HttpErrorCallback getErrorCallback(DruidAggregationQuery<?> query)

Callback for handling http errors.

Parameters:

query - The query associated with this error

Returns:

The callback handler

processResponse

void processResponse(com.fasterxml.jackson.databind.JsonNode json,
                     DruidAggregationQuery<?> query,
                     LoggingContext metadata)

Process the response json and respond to the original web request.

Parameters:

json - The json representing a druid data response

query - The query with the schema for processing this response

metadata - The LoggingContext to use