| Package | Description | 
|---|---|
| io.druid.guice | |
| io.druid.indexing.common | |
| io.druid.query | |
| io.druid.segment.realtime.appenderator | |
| io.druid.segment.realtime.plumber | |
| io.druid.server.coordination | 
| Modifier and Type | Method and Description | 
|---|---|
ExecutorService | 
RouterProcessingModule.getProcessingExecutorService(DruidProcessingConfig config)  | 
ExecutorService | 
DruidProcessingModule.getProcessingExecutorService(DruidProcessingConfig config,
                            ExecutorServiceMonitor executorServiceMonitor,
                            Lifecycle lifecycle)  | 
| Constructor and Description | 
|---|
TaskToolboxFactory(TaskConfig config,
                  TaskActionClientFactory taskActionClientFactory,
                  ServiceEmitter emitter,
                  DataSegmentPusher segmentPusher,
                  DataSegmentKiller dataSegmentKiller,
                  DataSegmentMover dataSegmentMover,
                  DataSegmentArchiver dataSegmentArchiver,
                  DataSegmentAnnouncer segmentAnnouncer,
                  DataSegmentServerAnnouncer serverAnnouncer,
                  SegmentHandoffNotifierFactory handoffNotifierFactory,
                  com.google.inject.Provider<QueryRunnerFactoryConglomerate> queryRunnerFactoryConglomerateProvider,
                  ExecutorService queryExecutorService,
                  MonitorScheduler monitorScheduler,
                  SegmentLoaderFactory segmentLoaderFactory,
                  com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                  IndexIO indexIO,
                  Cache cache,
                  CacheConfig cacheConfig,
                  IndexMergerV9 indexMergerV9,
                  DruidNodeAnnouncer druidNodeAnnouncer,
                  DruidNode druidNode,
                  LookupNodeService lookupNodeService,
                  DataNodeService dataNodeService)  | 
| Constructor and Description | 
|---|
IntervalChunkingQueryRunnerDecorator(ExecutorService executor,
                                    QueryWatcher queryWatcher,
                                    ServiceEmitter emitter)  | 
| Constructor and Description | 
|---|
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 | 
|---|
FlushingPlumberSchool(org.joda.time.Duration flushDuration,
                     ServiceEmitter emitter,
                     QueryRunnerFactoryConglomerate conglomerate,
                     DataSegmentAnnouncer segmentAnnouncer,
                     ExecutorService queryExecutorService,
                     IndexMergerV9 indexMergerV9,
                     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)  | 
| Constructor and Description | 
|---|
ServerManager(QueryRunnerFactoryConglomerate conglomerate,
             ServiceEmitter emitter,
             ExecutorService exec,
             ExecutorService cachingExec,
             com.fasterxml.jackson.databind.ObjectMapper objectMapper,
             Cache cache,
             CacheConfig cacheConfig,
             SegmentManager segmentManager,
             ServerConfig serverConfig)  | 
Copyright © 2011–2018. All rights reserved.