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>

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()
Sequence<T>	run(Query<T> query, Map<String,Object> context) Runs the given query and returns results in a time-ordered sequence

Methods inherited from class java.lang.Object

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

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

getNumOpenConnections

public int getNumOpenConnections()

run

public Sequence<T> run(Query<T> query,
                       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>

Returns: