com.yahoo.bard.webservice.web.responseprocessors

Class ResultSetResponseProcessor

java.lang.Object

com.yahoo.bard.webservice.web.responseprocessors.MappingResponseProcessor

com.yahoo.bard.webservice.web.responseprocessors.ResultSetResponseProcessor

All Implemented Interfaces:

ResponseProcessor

public class ResultSetResponseProcessor
extends MappingResponseProcessor
implements ResponseProcessor

Callback handler for JSON to be processed into result sets.

Field Summary

Fields

Modifier and Type	Field and Description
protected DruidResponseParser	druidResponseParser
protected Granularity	granularity
protected HttpResponseMaker	httpResponseMaker
protected rx.subjects.Subject<PreResponse,PreResponse>	responseEmitter

Fields inherited from class com.yahoo.bard.webservice.web.responseprocessors.MappingResponseProcessor

apiRequest, headers, mappers, objectMappers, responseContext

Constructor Summary

Constructors

Constructor and Description
ResultSetResponseProcessor(DataApiRequest apiRequest, rx.subjects.Subject<PreResponse,PreResponse> responseEmitter, DruidResponseParser druidResponseParser, ObjectMappersSuite objectMappers, HttpResponseMaker httpResponseMaker) Constructor.

Method Summary

Modifier and Type	Method and Description
ResultSet	buildResultSet(com.fasterxml.jackson.databind.JsonNode json, DruidAggregationQuery<?> druidQuery, org.joda.time.DateTimeZone dateTimeZone) Build a result set using the api request time grain.
HttpErrorCallback	getErrorCallback(DruidAggregationQuery<?> druidQuery) Callback for handling http errors.
FailureCallback	getFailureCallback(DruidAggregationQuery<?> druidQuery) Callback handler for unexpected failures.
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 com.yahoo.bard.webservice.web.responseprocessors.MappingResponseProcessor

buildHeaderList, buildResultSetMapperList, getDataApiRequest, getHeaders, getMappers, getObjectMappers, getResponseContext, getStandardError, getStandardFailure, mapResultSet

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.yahoo.bard.webservice.web.responseprocessors.ResponseProcessor

getResponseContext

Field Detail

responseEmitter

protected final rx.subjects.Subject<PreResponse,PreResponse> responseEmitter

granularity

protected final Granularity granularity

druidResponseParser

protected final DruidResponseParser druidResponseParser

httpResponseMaker

protected HttpResponseMaker httpResponseMaker

Constructor Detail

ResultSetResponseProcessor

public ResultSetResponseProcessor(DataApiRequest apiRequest,
                                  rx.subjects.Subject<PreResponse,PreResponse> responseEmitter,
                                  DruidResponseParser druidResponseParser,
                                  ObjectMappersSuite objectMappers,
                                  HttpResponseMaker httpResponseMaker)

Constructor.

Parameters:

apiRequest - The request for which the response is being processed

responseEmitter - The response channel to which the response will be sent

druidResponseParser - The parser for the Druid response

objectMappers - Jackson mappers to use for processing JSON

httpResponseMaker - Helper to make the HTTP response

Method Detail

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

buildResultSet

public ResultSet buildResultSet(com.fasterxml.jackson.databind.JsonNode json,
                                DruidAggregationQuery<?> druidQuery,
                                org.joda.time.DateTimeZone dateTimeZone)

Build a result set using the api request time grain.

Parameters:

json - The json representing the druid response.

druidQuery - The druid query being processed

dateTimeZone - The date time zone for parsing result rows

Returns:

The initial result set from the json node.