| Package | Description | 
|---|---|
| io.druid.indexing.common.index | |
| io.druid.segment.indexing | |
| io.druid.segment.realtime | |
| io.druid.segment.realtime.appenderator | |
| 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(File basePersistDirectory)  | 
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 | 
AppenderatorPlumber.getConfig()  | 
| Modifier and Type | Method and Description | 
|---|---|
Appenderator | 
DefaultRealtimeAppenderatorFactory.build(DataSchema schema,
     RealtimeTuningConfig config,
     FireDepartmentMetrics metrics)  | 
Appenderator | 
DefaultOfflineAppenderatorFactory.build(DataSchema schema,
     RealtimeTuningConfig config,
     FireDepartmentMetrics metrics)  | 
Appenderator | 
AppenderatorFactory.build(DataSchema schema,
     RealtimeTuningConfig config,
     FireDepartmentMetrics metrics)  | 
Plumber | 
AppenderatorPlumberSchool.findPlumber(DataSchema schema,
           RealtimeTuningConfig config,
           FireDepartmentMetrics metrics)  | 
| Constructor and Description | 
|---|
AppenderatorPlumber(DataSchema schema,
                   RealtimeTuningConfig config,
                   FireDepartmentMetrics metrics,
                   DataSegmentAnnouncer segmentAnnouncer,
                   SegmentPublisher segmentPublisher,
                   SegmentHandoffNotifier handoffNotifier,
                   Appenderator appenderator)  | 
| 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,
               ServiceEmitter emitter,
               QueryRunnerFactoryConglomerate conglomerate,
               DataSegmentAnnouncer segmentAnnouncer,
               ExecutorService queryExecutorService,
               IndexMerger indexMerger,
               IndexIO indexIO,
               Cache cache,
               CacheConfig cacheConfig,
               com.fasterxml.jackson.databind.ObjectMapper objectMapper)  | 
RealtimePlumber(DataSchema schema,
               RealtimeTuningConfig config,
               FireDepartmentMetrics metrics,
               ServiceEmitter emitter,
               QueryRunnerFactoryConglomerate conglomerate,
               DataSegmentAnnouncer segmentAnnouncer,
               ExecutorService queryExecutorService,
               DataSegmentPusher dataSegmentPusher,
               SegmentPublisher segmentPublisher,
               SegmentHandoffNotifier handoffNotifier,
               IndexMerger indexMerger,
               IndexIO indexIO,
               Cache cache,
               CacheConfig cacheConfig,
               com.fasterxml.jackson.databind.ObjectMapper objectMapper)  | 
Copyright © 2011–2018. All rights reserved.