com.yahoo.bard.webservice.data

Class DruidResponseParser

java.lang.Object

com.yahoo.bard.webservice.data.DruidResponseParser

@Singleton
public class DruidResponseParser
extends Object

A class for building result sets from Druid Responses.

Constructor Summary

Constructors

Constructor and Description
DruidResponseParser()

Method Summary

Modifier and Type	Method and Description
Stream<Column>	buildSchemaColumns(DruidAggregationQuery<?> druidQuery) Produce the schema-defining columns for a given druid query.
ResultSet	parse(com.fasterxml.jackson.databind.JsonNode jsonResult, ResultSetSchema schema, QueryType queryType, org.joda.time.DateTimeZone dateTimeZone) Parse Druid GroupBy result into ResultSet.

Methods inherited from class java.lang.Object

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

Constructor Detail

DruidResponseParser

public DruidResponseParser()

Method Detail

parse

public ResultSet parse(com.fasterxml.jackson.databind.JsonNode jsonResult,
                       ResultSetSchema schema,
                       QueryType queryType,
                       org.joda.time.DateTimeZone dateTimeZone)

Parse Druid GroupBy result into ResultSet.

Parameters:

jsonResult - Druid results in json

schema - Schema for results

queryType - the type of query, note that this implementation only supports instances of DefaultQueryType

dateTimeZone - the time zone used for format the results

Returns:

the set of results

buildSchemaColumns

public Stream<Column> buildSchemaColumns(DruidAggregationQuery<?> druidQuery)

Produce the schema-defining columns for a given druid query.

Parameters:

druidQuery - The query being modelled.

Returns:

A stream of columns based on the signature of the Druid Query.