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, com.metamx.http.client.HttpClient httpClient, String host, com.metamx.emitter.service.ServiceEmitter emitter)

Method Summary

Modifier and Type	Method and Description
int	getNumOpenConnections()
static Map<String,Object>	makeResponseContextForQuery(Query query, long startTimeMillis)
Sequence<T>	run(QueryPlus<T> queryPlus, Map<String,Object> context) Runs the given query and returns results in a time-ordered sequence.
String	toString()
static <T,QueryType extends Query<T>> QueryType	withDefaultTimeoutAndMaxScatterGatherBytes(QueryType query, ServerConfig serverConfig)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.druid.query.QueryRunner

run

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,
                         com.metamx.http.client.HttpClient httpClient,
                         String host,
                         com.metamx.emitter.service.ServiceEmitter emitter)

Method Detail

withDefaultTimeoutAndMaxScatterGatherBytes

public static <T,QueryType extends Query<T>> QueryType withDefaultTimeoutAndMaxScatterGatherBytes(QueryType query,
                                                                                                  ServerConfig serverConfig)

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