org.apache.druid.segment.realtime

Class RealtimeManager

java.lang.Object

org.apache.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)
<T> QueryRunner<T>	getQueryRunnerForSegments(Query<T> query, Iterable<SegmentDescriptor> specs)
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()

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)

Specified by:

getQueryRunnerForIntervals in interface QuerySegmentWalker

getQueryRunnerForSegments

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

Specified by:

getQueryRunnerForSegments in interface QuerySegmentWalker