| Package | Description |
|---|---|
| io.druid.guice | |
| io.druid.indexing.common | |
| io.druid.query | |
| io.druid.segment.realtime.plumber | |
| io.druid.server.coordination |
| Modifier and Type | Method and Description |
|---|---|
ExecutorService |
DruidProcessingModule.getProcessingExecutorService(com.metamx.common.concurrent.ExecutorServiceConfig config,
com.metamx.emitter.service.ServiceEmitter emitter,
com.metamx.common.lifecycle.Lifecycle lifecycle) |
| Constructor and Description |
|---|
TaskToolboxFactory(TaskConfig config,
TaskActionClientFactory taskActionClientFactory,
com.metamx.emitter.service.ServiceEmitter emitter,
io.druid.segment.loading.DataSegmentPusher segmentPusher,
io.druid.segment.loading.DataSegmentKiller dataSegmentKiller,
io.druid.segment.loading.DataSegmentMover dataSegmentMover,
io.druid.segment.loading.DataSegmentArchiver dataSegmentArchiver,
DataSegmentAnnouncer segmentAnnouncer,
FilteredServerView newSegmentServerView,
QueryRunnerFactoryConglomerate queryRunnerFactoryConglomerate,
ExecutorService queryExecutorService,
com.metamx.metrics.MonitorScheduler monitorScheduler,
SegmentLoaderFactory segmentLoaderFactory,
com.fasterxml.jackson.databind.ObjectMapper objectMapper) |
| Constructor and Description |
|---|
IntervalChunkingQueryRunnerDecorator(ExecutorService executor,
QueryWatcher queryWatcher,
com.metamx.emitter.service.ServiceEmitter emitter) |
| Constructor and Description |
|---|
FlushingPlumberSchool(org.joda.time.Duration flushDuration,
com.metamx.emitter.service.ServiceEmitter emitter,
QueryRunnerFactoryConglomerate conglomerate,
DataSegmentAnnouncer segmentAnnouncer,
ExecutorService queryExecutorService) |
RealtimePlumberSchool(com.metamx.emitter.service.ServiceEmitter emitter,
QueryRunnerFactoryConglomerate conglomerate,
io.druid.segment.loading.DataSegmentPusher dataSegmentPusher,
DataSegmentAnnouncer segmentAnnouncer,
SegmentPublisher segmentPublisher,
FilteredServerView serverView,
ExecutorService executorService) |
| Constructor and Description |
|---|
ServerManager(SegmentLoader segmentLoader,
QueryRunnerFactoryConglomerate conglomerate,
com.metamx.emitter.service.ServiceEmitter emitter,
ExecutorService exec,
ExecutorService cachingExec,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
Cache cache,
CacheConfig cacheConfig) |
Copyright © 2011–2015. All rights reserved.