| Package | Description |
|---|---|
| io.druid.client | |
| io.druid.guice | |
| io.druid.indexing.common | |
| io.druid.segment.realtime.plumber | |
| io.druid.server.coordination |
| Constructor and Description |
|---|
CachingClusteredClient(QueryToolChestWarehouse warehouse,
TimelineServerView serverView,
Cache cache,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
ExecutorService backgroundExecutorService,
CacheConfig cacheConfig) |
CachingQueryRunner(String segmentIdentifier,
io.druid.query.SegmentDescriptor segmentDescriptor,
com.fasterxml.jackson.databind.ObjectMapper mapper,
Cache cache,
QueryToolChest toolchest,
QueryRunner<T> base,
ExecutorService backgroundExecutorService,
CacheConfig cacheConfig) |
| Modifier and Type | Method and Description |
|---|---|
ExecutorService |
DruidProcessingModule.getBackgroundExecutorService(CacheConfig cacheConfig) |
| Modifier and Type | Method and Description |
|---|---|
CacheConfig |
TaskToolbox.getCacheConfig() |
| Constructor and Description |
|---|
TaskToolbox(TaskConfig config,
Task task,
TaskActionClient taskActionClient,
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,
SegmentHandoffNotifierFactory handoffNotifierFactory,
QueryRunnerFactoryConglomerate queryRunnerFactoryConglomerate,
ExecutorService queryExecutorService,
com.metamx.metrics.MonitorScheduler monitorScheduler,
SegmentLoader segmentLoader,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
File taskWorkDir,
Cache cache,
CacheConfig cacheConfig) |
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,
SegmentHandoffNotifierFactory handoffNotifierFactory,
QueryRunnerFactoryConglomerate queryRunnerFactoryConglomerate,
ExecutorService queryExecutorService,
com.metamx.metrics.MonitorScheduler monitorScheduler,
SegmentLoaderFactory segmentLoaderFactory,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
Cache cache,
CacheConfig cacheConfig) |
| Constructor and Description |
|---|
FlushingPlumber(org.joda.time.Duration flushDuration,
DataSchema schema,
RealtimeTuningConfig config,
FireDepartmentMetrics metrics,
com.metamx.emitter.service.ServiceEmitter emitter,
QueryRunnerFactoryConglomerate conglomerate,
DataSegmentAnnouncer segmentAnnouncer,
ExecutorService queryExecutorService,
Cache cache,
CacheConfig cacheConfig,
com.fasterxml.jackson.databind.ObjectMapper objectMapper) |
FlushingPlumberSchool(org.joda.time.Duration flushDuration,
com.metamx.emitter.service.ServiceEmitter emitter,
QueryRunnerFactoryConglomerate conglomerate,
DataSegmentAnnouncer segmentAnnouncer,
ExecutorService queryExecutorService,
Cache cache,
CacheConfig cacheConfig,
com.fasterxml.jackson.databind.ObjectMapper objectMapper) |
RealtimePlumber(DataSchema schema,
RealtimeTuningConfig config,
FireDepartmentMetrics metrics,
com.metamx.emitter.service.ServiceEmitter emitter,
QueryRunnerFactoryConglomerate conglomerate,
DataSegmentAnnouncer segmentAnnouncer,
ExecutorService queryExecutorService,
io.druid.segment.loading.DataSegmentPusher dataSegmentPusher,
SegmentPublisher segmentPublisher,
SegmentHandoffNotifier handoffNotifier,
Cache cache,
CacheConfig cacheConfig,
com.fasterxml.jackson.databind.ObjectMapper objectMapper) |
RealtimePlumberSchool(com.metamx.emitter.service.ServiceEmitter emitter,
QueryRunnerFactoryConglomerate conglomerate,
io.druid.segment.loading.DataSegmentPusher dataSegmentPusher,
DataSegmentAnnouncer segmentAnnouncer,
SegmentPublisher segmentPublisher,
SegmentHandoffNotifierFactory handoffNotifierFactory,
ExecutorService executorService,
Cache cache,
CacheConfig cacheConfig,
com.fasterxml.jackson.databind.ObjectMapper objectMapper) |
| 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–2016. All rights reserved.