| Package | Description | 
|---|---|
| io.druid.guice | |
| io.druid.indexing.common.task | |
| io.druid.metadata | |
| io.druid.segment.realtime | |
| io.druid.segment.realtime.appenderator | |
| io.druid.segment.realtime.plumber | 
| Modifier and Type | Method and Description | 
|---|---|
SegmentPublisher | 
NoopSegmentPublisherProvider.get()  | 
| Modifier and Type | Class and Description | 
|---|---|
static class  | 
RealtimeIndexTask.TaskActionSegmentPublisher  | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
MetadataSegmentPublisher  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
SQLMetadataSegmentPublisher  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
NoopSegmentPublisher  | 
| Constructor and Description | 
|---|
AppenderatorPlumber(DataSchema schema,
                   RealtimeTuningConfig config,
                   FireDepartmentMetrics metrics,
                   DataSegmentAnnouncer segmentAnnouncer,
                   SegmentPublisher segmentPublisher,
                   SegmentHandoffNotifier handoffNotifier,
                   Appenderator appenderator)  | 
AppenderatorPlumberSchool(AppenderatorFactory appenderatorFactory,
                         DataSegmentAnnouncer segmentAnnouncer,
                         SegmentHandoffNotifierFactory handoffNotifierFactory,
                         SegmentPublisher segmentPublisher)  | 
| Constructor and Description | 
|---|
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)  | 
RealtimePlumberSchool(ServiceEmitter emitter,
                     QueryRunnerFactoryConglomerate conglomerate,
                     DataSegmentPusher dataSegmentPusher,
                     DataSegmentAnnouncer segmentAnnouncer,
                     SegmentPublisher segmentPublisher,
                     SegmentHandoffNotifierFactory handoffNotifierFactory,
                     ExecutorService executorService,
                     IndexMergerV9 indexMergerV9,
                     IndexIO indexIO,
                     Cache cache,
                     CacheConfig cacheConfig,
                     com.fasterxml.jackson.databind.ObjectMapper objectMapper)  | 
Copyright © 2011–2018. All rights reserved.