io.druid.client

Class CachingClusteredClient

java.lang.Object

io.druid.client.CachingClusteredClient

All Implemented Interfaces:

QuerySegmentWalker

public class CachingClusteredClient
extends Object
implements QuerySegmentWalker

Constructor Summary

Constructors

Constructor and Description
CachingClusteredClient(QueryToolChestWarehouse warehouse, TimelineServerView serverView, Cache cache, com.fasterxml.jackson.databind.ObjectMapper objectMapper, ExecutorService backgroundExecutorService, CacheConfig cacheConfig)

Method Summary

Modifier and Type	Method and Description
<T> QueryRunner<T>	getQueryRunnerForIntervals(Query<T> query, Iterable<org.joda.time.Interval> intervals) Gets the Queryable for a given interval, the Queryable returned can be any version(s) or partitionNumber(s) such that it represents the interval.
<T> QueryRunner<T>	getQueryRunnerForSegments(Query<T> query, Iterable<SegmentDescriptor> specs) Gets the Queryable for a given list of SegmentSpecs.

Methods inherited from class java.lang.Object

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

Constructor Detail

CachingClusteredClient

@Inject
public CachingClusteredClient(QueryToolChestWarehouse warehouse,
                                      TimelineServerView serverView,
                                      Cache cache,
                                      com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                                      ExecutorService backgroundExecutorService,
                                      CacheConfig cacheConfig)

Method Detail

getQueryRunnerForIntervals

public <T> QueryRunner<T> getQueryRunnerForIntervals(Query<T> query,
                                                     Iterable<org.joda.time.Interval> intervals)

Description copied from interface: QuerySegmentWalker

Gets the Queryable for a given interval, the Queryable returned can be any version(s) or partitionNumber(s) such that it represents the interval.

Specified by:

getQueryRunnerForIntervals in interface QuerySegmentWalker

Type Parameters:

T - query result type

Parameters:

query - the query to find a Queryable for

intervals - the intervals to find a Queryable for

Returns:

a Queryable object that represents the interval

getQueryRunnerForSegments

public <T> QueryRunner<T> getQueryRunnerForSegments(Query<T> query,
                                                    Iterable<SegmentDescriptor> specs)

Description copied from interface: QuerySegmentWalker

Gets the Queryable for a given list of SegmentSpecs.

Specified by:

getQueryRunnerForSegments in interface QuerySegmentWalker

Type Parameters:

T - the query result type

Parameters:

query - the query to return a Queryable for

specs - the list of SegmentSpecs to find a Queryable for

Returns:

the Queryable object with the given SegmentSpecs