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.