com.yahoo.bard.webservice.web.responseprocessors

Class EtagCacheResponseProcessor

java.lang.Object

com.yahoo.bard.webservice.web.responseprocessors.EtagCacheResponseProcessor

All Implemented Interfaces:

FullResponseProcessor, ResponseProcessor

public class EtagCacheResponseProcessor
extends Object
implements FullResponseProcessor

A response processor which caches the results if appropriate after completing a query according to etag value.

Constructor Summary

Constructors

Constructor and Description
EtagCacheResponseProcessor(ResponseProcessor next, String cacheKey, TupleDataCache<String,String,String> dataCache, com.fasterxml.jackson.databind.ObjectMapper mapper) 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

Constructor Detail

EtagCacheResponseProcessor

public EtagCacheResponseProcessor(@NotNull
                                  ResponseProcessor next,
                                  @NotNull
                                  String cacheKey,
                                  @NotNull
                                  TupleDataCache<String,String,String> dataCache,
                                  @NotNull
                                  com.fasterxml.jackson.databind.ObjectMapper mapper)

Constructor.

Parameters:

next - Next ResponseProcessor in the chain

cacheKey - Key into which to write a cache entry

dataCache - The cache into which to write a cache entry

mapper - An object mapper to use for processing Json

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