| Package | Description | 
|---|---|
| io.druid.segment.realtime.appenderator | |
| io.druid.segment.realtime.plumber | 
| Constructor and Description | 
|---|
AppenderatorPlumber(DataSchema schema,
                   RealtimeTuningConfig config,
                   FireDepartmentMetrics metrics,
                   DataSegmentAnnouncer segmentAnnouncer,
                   SegmentPublisher segmentPublisher,
                   SegmentHandoffNotifier handoffNotifier,
                   Appenderator appenderator)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
CoordinatorBasedSegmentHandoffNotifier  | 
| Modifier and Type | Method and Description | 
|---|---|
SegmentHandoffNotifier | 
SegmentHandoffNotifierFactory.createSegmentHandoffNotifier(String dataSource)  | 
SegmentHandoffNotifier | 
NoopSegmentHandoffNotifierFactory.createSegmentHandoffNotifier(String dataSource)  | 
SegmentHandoffNotifier | 
CoordinatorBasedSegmentHandoffNotifierFactory.createSegmentHandoffNotifier(String dataSource)  | 
| 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)  | 
Copyright © 2011–2018. All rights reserved.