| Package | Description | 
|---|---|
| io.druid.indexing.common.index | |
| io.druid.segment.realtime | |
| io.druid.segment.realtime.plumber | 
| Modifier and Type | Method and Description | 
|---|---|
Plumber | 
YeOldePlumberSchool.findPlumber(DataSchema schema,
           RealtimeTuningConfig config,
           FireDepartmentMetrics metrics)  | 
| Modifier and Type | Method and Description | 
|---|---|
FireDepartmentMetrics | 
FireDepartment.getMetrics()  | 
FireDepartmentMetrics | 
RealtimeManager.getMetrics(String datasource)  | 
FireDepartmentMetrics | 
FireDepartmentMetrics.merge(FireDepartmentMetrics other)
merge other FireDepartmentMetrics, will modify this object's data 
 | 
FireDepartmentMetrics | 
FireDepartmentMetrics.snapshot()  | 
| Modifier and Type | Method and Description | 
|---|---|
FireDepartmentMetrics | 
FireDepartmentMetrics.merge(FireDepartmentMetrics other)
merge other FireDepartmentMetrics, will modify this object's data 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Plumber | 
RealtimePlumberSchool.findPlumber(DataSchema schema,
           RealtimeTuningConfig config,
           FireDepartmentMetrics metrics)  | 
Plumber | 
PlumberSchool.findPlumber(DataSchema schema,
           RealtimeTuningConfig config,
           FireDepartmentMetrics metrics)
Creates a Plumber 
 | 
Plumber | 
FlushingPlumberSchool.findPlumber(DataSchema schema,
           RealtimeTuningConfig config,
           FireDepartmentMetrics metrics)  | 
| Constructor and Description | 
|---|
FlushingPlumber(org.joda.time.Duration flushDuration,
               DataSchema schema,
               RealtimeTuningConfig config,
               FireDepartmentMetrics metrics,
               com.metamx.emitter.service.ServiceEmitter emitter,
               QueryRunnerFactoryConglomerate conglomerate,
               DataSegmentAnnouncer segmentAnnouncer,
               ExecutorService queryExecutorService)  | 
RealtimePlumber(DataSchema schema,
               RealtimeTuningConfig config,
               FireDepartmentMetrics metrics,
               com.metamx.emitter.service.ServiceEmitter emitter,
               QueryRunnerFactoryConglomerate conglomerate,
               DataSegmentAnnouncer segmentAnnouncer,
               ExecutorService queryExecutorService,
               io.druid.segment.loading.DataSegmentPusher dataSegmentPusher,
               SegmentPublisher segmentPublisher,
               FilteredServerView serverView)  | 
Copyright © 2011–2015. All rights reserved.