| Package | Description |
|---|---|
| io.druid.indexing.common | |
| io.druid.segment.realtime | |
| io.druid.server.coordination |
| Modifier and Type | Method and Description |
|---|---|
DataSegmentServerAnnouncer |
TaskToolbox.getDataSegmentServerAnnouncer() |
| Constructor and Description |
|---|
TaskToolbox(TaskConfig config,
TaskActionClient taskActionClient,
com.metamx.emitter.service.ServiceEmitter emitter,
DataSegmentPusher segmentPusher,
DataSegmentKiller dataSegmentKiller,
DataSegmentMover dataSegmentMover,
DataSegmentArchiver dataSegmentArchiver,
DataSegmentAnnouncer segmentAnnouncer,
DataSegmentServerAnnouncer serverAnnouncer,
SegmentHandoffNotifierFactory handoffNotifierFactory,
com.google.inject.Provider<QueryRunnerFactoryConglomerate> queryRunnerFactoryConglomerateProvider,
ExecutorService queryExecutorService,
com.metamx.metrics.MonitorScheduler monitorScheduler,
SegmentLoader segmentLoader,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
File taskWorkDir,
IndexMerger indexMerger,
IndexIO indexIO,
Cache cache,
CacheConfig cacheConfig,
IndexMergerV9 indexMergerV9) |
TaskToolboxFactory(TaskConfig config,
TaskActionClientFactory taskActionClientFactory,
com.metamx.emitter.service.ServiceEmitter emitter,
DataSegmentPusher segmentPusher,
DataSegmentKiller dataSegmentKiller,
DataSegmentMover dataSegmentMover,
DataSegmentArchiver dataSegmentArchiver,
DataSegmentAnnouncer segmentAnnouncer,
DataSegmentServerAnnouncer serverAnnouncer,
SegmentHandoffNotifierFactory handoffNotifierFactory,
com.google.inject.Provider<QueryRunnerFactoryConglomerate> queryRunnerFactoryConglomerateProvider,
ExecutorService queryExecutorService,
com.metamx.metrics.MonitorScheduler monitorScheduler,
SegmentLoaderFactory segmentLoaderFactory,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
IndexMerger indexMerger,
IndexIO indexIO,
Cache cache,
CacheConfig cacheConfig,
IndexMergerV9 indexMergerV9) |
| Constructor and Description |
|---|
RealtimeManager(List<FireDepartment> fireDepartments,
QueryRunnerFactoryConglomerate conglomerate,
DataSegmentServerAnnouncer serverAnnouncer) |
| Modifier and Type | Class and Description |
|---|---|
class |
CuratorDataSegmentServerAnnouncer |
| Constructor and Description |
|---|
ZkCoordinator(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
SegmentLoaderConfig config,
ZkPathsConfig zkPaths,
DruidServerMetadata me,
DataSegmentAnnouncer announcer,
DataSegmentServerAnnouncer serverAnnouncer,
org.apache.curator.framework.CuratorFramework curator,
SegmentManager segmentManager,
ScheduledExecutorFactory factory) |
Copyright © 2011–2017. All rights reserved.