| Package | Description | 
|---|---|
| io.druid.indexer | |
| io.druid.indexer.updater | |
| io.druid.segment | |
| io.druid.segment.realtime.appenderator | |
| io.druid.segment.realtime.plumber | 
| Modifier and Type | Field and Description | 
|---|---|
static IndexMerger | 
HadoopDruidIndexerConfig.INDEX_MERGER_V9  | 
| Modifier and Type | Field and Description | 
|---|---|
static IndexMerger | 
HadoopDruidConverterConfig.INDEX_MERGER  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
IndexMergerV9  | 
| Modifier and Type | Method and Description | 
|---|---|
static Appenderator | 
Appenderators.createOffline(DataSchema schema,
             AppenderatorConfig config,
             FireDepartmentMetrics metrics,
             DataSegmentPusher dataSegmentPusher,
             com.fasterxml.jackson.databind.ObjectMapper objectMapper,
             IndexIO indexIO,
             IndexMerger indexMerger)  | 
static Appenderator | 
Appenderators.createRealtime(DataSchema schema,
              AppenderatorConfig config,
              FireDepartmentMetrics metrics,
              DataSegmentPusher dataSegmentPusher,
              com.fasterxml.jackson.databind.ObjectMapper objectMapper,
              IndexIO indexIO,
              IndexMerger indexMerger,
              QueryRunnerFactoryConglomerate conglomerate,
              DataSegmentAnnouncer segmentAnnouncer,
              ServiceEmitter emitter,
              ExecutorService queryExecutorService,
              Cache cache,
              CacheConfig cacheConfig)  | 
| Constructor and Description | 
|---|
AppenderatorImpl(DataSchema schema,
                AppenderatorConfig tuningConfig,
                FireDepartmentMetrics metrics,
                DataSegmentPusher dataSegmentPusher,
                com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                QueryRunnerFactoryConglomerate conglomerate,
                DataSegmentAnnouncer segmentAnnouncer,
                ServiceEmitter emitter,
                ExecutorService queryExecutorService,
                IndexIO indexIO,
                IndexMerger indexMerger,
                Cache cache,
                CacheConfig cacheConfig)  | 
DefaultOfflineAppenderatorFactory(DataSegmentPusher dataSegmentPusher,
                                 com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                                 IndexIO indexIO,
                                 IndexMerger indexMerger)  | 
DefaultRealtimeAppenderatorFactory(ServiceEmitter emitter,
                                  QueryRunnerFactoryConglomerate conglomerate,
                                  DataSegmentAnnouncer segmentAnnouncer,
                                  ExecutorService queryExecutorService,
                                  DataSegmentPusher dataSegmentPusher,
                                  com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                                  IndexIO indexIO,
                                  IndexMerger indexMerger,
                                  Cache cache,
                                  CacheConfig cacheConfig)  | 
| 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.