org.apache.druid.client

Class DirectDruidClient<T>

java.lang.Object

org.apache.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()
static void	removeMagicResponseContextFields(Map<String,Object> responseContext) Removes the magical fields added by makeResponseContextForQuery().
Sequence<T>	run(QueryPlus<T> queryPlus, Map<String,Object> context)
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().

makeResponseContextForQuery

public static Map<String,Object> makeResponseContextForQuery()

getNumOpenConnections

public int getNumOpenConnections()

run

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

Specified by:

run in interface QueryRunner<T>

toString

public String toString()

Overrides:

toString in class Object