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(SegmentLoader segmentLoader, QueryRunnerFactoryConglomerate conglomerate, com.metamx.emitter.service.ServiceEmitter emitter, ExecutorService exec, ExecutorService cachingExec, com.fasterxml.jackson.databind.ObjectMapper objectMapper, Cache cache, CacheConfig cacheConfig)

Method Summary

Modifier and Type	Method and Description
void	dropSegment(DataSegment segment)
Map<String,Long>	getDataSourceCounts()
Map<String,Long>	getDataSourceSizes()
<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.
boolean	isSegmentCached(DataSegment segment)
boolean	loadSegment(DataSegment segment) Load a single segment.

Methods inherited from class java.lang.Object

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

Constructor Detail

ServerManager

@Inject
public ServerManager(SegmentLoader segmentLoader,
                             QueryRunnerFactoryConglomerate conglomerate,
                             com.metamx.emitter.service.ServiceEmitter emitter,
                             ExecutorService exec,
                             ExecutorService cachingExec,
                             com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                             Cache cache,
                             CacheConfig cacheConfig)

Method Detail

getDataSourceSizes

public Map<String,Long> getDataSourceSizes()

getDataSourceCounts

public Map<String,Long> getDataSourceCounts()

isSegmentCached

public boolean isSegmentCached(DataSegment segment)
                        throws SegmentLoadingException

Throws:

SegmentLoadingException

loadSegment

public boolean loadSegment(DataSegment segment)
                    throws SegmentLoadingException

Load a single segment.

Parameters:

segment - segment to load

Returns:

true if the segment was newly loaded, false if it was already loaded

Throws:

SegmentLoadingException - if the segment cannot be loaded

dropSegment

public void dropSegment(DataSegment segment)
                 throws SegmentLoadingException

Throws:

SegmentLoadingException

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