io.druid.segment.realtime

Class RealtimeManager

java.lang.Object

io.druid.segment.realtime.RealtimeManager

All Implemented Interfaces:

QuerySegmentWalker

public class RealtimeManager
extends Object
implements QuerySegmentWalker

Constructor Summary

Constructors

Constructor and Description
RealtimeManager(List<FireDepartment> fireDepartments, QueryRunnerFactoryConglomerate conglomerate, DataSegmentServerAnnouncer serverAnnouncer)

Method Summary

Modifier and Type	Method and Description
FireDepartmentMetrics	getMetrics(String datasource)
<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.
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

RealtimeManager

@Inject
public RealtimeManager(List<FireDepartment> fireDepartments,
                               QueryRunnerFactoryConglomerate conglomerate,
                               DataSegmentServerAnnouncer serverAnnouncer)

Method Detail

start

public void start()
           throws IOException

Throws:

IOException

stop

public void stop()

getMetrics

public FireDepartmentMetrics getMetrics(String datasource)

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