io.druid.server

Class ClientQuerySegmentWalker

java.lang.Object

io.druid.server.ClientQuerySegmentWalker

All Implemented Interfaces:

QuerySegmentWalker

public class ClientQuerySegmentWalker
extends Object
implements QuerySegmentWalker

Constructor Summary

Constructors

Constructor and Description
ClientQuerySegmentWalker(com.metamx.emitter.service.ServiceEmitter emitter, CachingClusteredClient baseClient, QueryToolChestWarehouse warehouse, RetryQueryRunnerConfig retryConfig, com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Method Summary

Methods

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<io.druid.query.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

ClientQuerySegmentWalker

@Inject
public ClientQuerySegmentWalker(com.metamx.emitter.service.ServiceEmitter emitter,
                               CachingClusteredClient baseClient,
                               QueryToolChestWarehouse warehouse,
                               RetryQueryRunnerConfig retryConfig,
                               com.fasterxml.jackson.databind.ObjectMapper objectMapper)

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<io.druid.query.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