com.yahoo.bard.webservice.web.responseprocessors

Class SplitQueryResponseProcessor

java.lang.Object

com.yahoo.bard.webservice.web.responseprocessors.SplitQueryResponseProcessor

All Implemented Interfaces:

ResponseProcessor

public class SplitQueryResponseProcessor
extends Object
implements ResponseProcessor

This response processor receives a list of expected intervals. As responses arrives, it stores the responses until all expected intervals have arrived, at which point it passes the concatenated Json content from each of the calls to its next processor.

Field Summary

Fields

Modifier and Type	Field and Description
static String	EXTRA_RETURN_FORMAT
static String	UNEXPECTED_INTERVAL_FORMAT

Constructor Summary

Constructors

Constructor and Description
SplitQueryResponseProcessor(ResponseProcessor next, DataApiRequest request, DruidAggregationQuery<?> druidQuery, Map<org.joda.time.Interval,AtomicInteger> expectedIntervals, RequestLog logCtx) Constructor.

Method Summary

Modifier and Type	Method and Description
HttpErrorCallback	getErrorCallback(DruidAggregationQuery<?> druidQuery) Callback for handling http errors.
FailureCallback	getFailureCallback(DruidAggregationQuery<?> druidQuery) 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<?> druidQuery, LoggingContext metadata) Process the response json and respond to the original web request.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

EXTRA_RETURN_FORMAT

public static final String EXTRA_RETURN_FORMAT

See Also:

Constant Field Values

UNEXPECTED_INTERVAL_FORMAT

public static final String UNEXPECTED_INTERVAL_FORMAT

See Also:

Constant Field Values

Constructor Detail

SplitQueryResponseProcessor

public SplitQueryResponseProcessor(ResponseProcessor next,
                                   DataApiRequest request,
                                   DruidAggregationQuery<?> druidQuery,
                                   Map<org.joda.time.Interval,AtomicInteger> expectedIntervals,
                                   RequestLog logCtx)

Constructor.

Parameters:

next - The next delegate response processor

request - The request for this response

druidQuery - The unmodified druid query for this response

expectedIntervals - A map of expected interval status flags

logCtx - The request log logging context

Method Detail

getResponseContext

public ResponseContext getResponseContext()

Description copied from interface: ResponseProcessor

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

Specified by:

getResponseContext in interface ResponseProcessor

Returns:

The context data

getFailureCallback

public FailureCallback getFailureCallback(DruidAggregationQuery<?> druidQuery)

Description copied from interface: ResponseProcessor

Callback handler for unexpected failures.

Specified by:

getFailureCallback in interface ResponseProcessor

Parameters:

druidQuery - The query associated with this failure

Returns:

The callback handler

getErrorCallback

public HttpErrorCallback getErrorCallback(DruidAggregationQuery<?> druidQuery)

Description copied from interface: ResponseProcessor

Callback for handling http errors.

Specified by:

getErrorCallback in interface ResponseProcessor

Parameters:

druidQuery - The query associated with this error

Returns:

The callback handler

processResponse

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

Description copied from interface: ResponseProcessor

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

Specified by:

processResponse in interface ResponseProcessor

Parameters:

json - The json representing a druid data response

druidQuery - The query with the schema for processing this response

metadata - The LoggingContext to use