| Package | Description | 
|---|---|
| io.druid.indexing.common.index | |
| io.druid.segment.indexing | |
| 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 | 
|---|---|
static RealtimeTuningConfig | 
RealtimeTuningConfig.makeDefaultTuningConfig()  | 
RealtimeTuningConfig | 
RealtimeTuningConfig.withBasePersistDirectory(File dir)  | 
RealtimeTuningConfig | 
RealtimeTuningConfig.withVersioningPolicy(VersioningPolicy policy)  | 
| Modifier and Type | Method and Description | 
|---|---|
RealtimeTuningConfig | 
FireDepartment.getTuningConfig()  | 
| Constructor and Description | 
|---|
FireDepartment(DataSchema dataSchema,
              RealtimeIOConfig ioConfig,
              RealtimeTuningConfig tuningConfig)  | 
| Modifier and Type | Method and Description | 
|---|---|
RealtimeTuningConfig | 
RealtimePlumber.getConfig()  | 
| 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)  | 
Sink(org.joda.time.Interval interval,
    DataSchema schema,
    RealtimeTuningConfig config,
    String version)  | 
Sink(org.joda.time.Interval interval,
    DataSchema schema,
    RealtimeTuningConfig config,
    String version,
    List<FireHydrant> hydrants)  | 
Copyright © 2015. All rights reserved.