io.druid.client

Class DirectDruidClient<T>

java.lang.Object

io.druid.client.DirectDruidClient<T>

All Implemented Interfaces:

QueryRunner<T>

public class DirectDruidClient<T>
extends Object
implements QueryRunner<T>

Field Summary

Fields

Modifier and Type	Field and Description
static String	QUERY_FAIL_TIME
static String	QUERY_TOTAL_BYTES_GATHERED

Constructor Summary

Constructors

Constructor and Description
DirectDruidClient(QueryToolChestWarehouse warehouse, QueryWatcher queryWatcher, com.fasterxml.jackson.databind.ObjectMapper objectMapper, HttpClient httpClient, String scheme, String host, ServiceEmitter emitter)

Method Summary

Modifier and Type	Method and Description
int	getNumOpenConnections()
static Map<String,Object>	makeResponseContextForQuery(Query query, long startTimeMillis)
static void	removeMagicResponseContextFields(Map<String,Object> responseContext) Removes the magical fields added by makeResponseContextForQuery(Query, long).
Sequence<T>	run(QueryPlus<T> queryPlus, Map<String,Object> context) Runs the given query and returns results in a time-ordered sequence.
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

QUERY_FAIL_TIME

public static final String QUERY_FAIL_TIME

See Also:

Constant Field Values

QUERY_TOTAL_BYTES_GATHERED

public static final String QUERY_TOTAL_BYTES_GATHERED

See Also:

Constant Field Values

Constructor Detail

DirectDruidClient

public DirectDruidClient(QueryToolChestWarehouse warehouse,
                         QueryWatcher queryWatcher,
                         com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                         HttpClient httpClient,
                         String scheme,
                         String host,
                         ServiceEmitter emitter)

Method Detail

removeMagicResponseContextFields

public static void removeMagicResponseContextFields(Map<String,Object> responseContext)

Removes the magical fields added by makeResponseContextForQuery(Query, long).

makeResponseContextForQuery

public static Map<String,Object> makeResponseContextForQuery(Query query,
                                                             long startTimeMillis)

getNumOpenConnections

public int getNumOpenConnections()

run

public Sequence<T> run(QueryPlus<T> queryPlus,
                       Map<String,Object> context)

Description copied from interface: QueryRunner

Runs the given query and returns results in a time-ordered sequence.

Specified by:

run in interface QueryRunner<T>

toString

public String toString()

Overrides:

toString in class Object