io.druid.server.coordination

Class ServerManager

java.lang.Object

io.druid.server.coordination.ServerManager

All Implemented Interfaces:

QuerySegmentWalker

public class ServerManager
extends Object
implements QuerySegmentWalker

Constructor Summary

Constructors

Constructor and Description
ServerManager(QueryRunnerFactoryConglomerate conglomerate, ServiceEmitter emitter, ExecutorService exec, ExecutorService cachingExec, com.fasterxml.jackson.databind.ObjectMapper objectMapper, Cache cache, CacheConfig cacheConfig, SegmentManager segmentManager, ServerConfig serverConfig)

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

ServerManager

@Inject
public ServerManager(QueryRunnerFactoryConglomerate conglomerate,
                             ServiceEmitter emitter,
                             ExecutorService exec,
                             ExecutorService cachingExec,
                             com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                             Cache cache,
                             CacheConfig cacheConfig,
                             SegmentManager segmentManager,
                             ServerConfig serverConfig)

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