| 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,
Task task,
TaskActionClient taskActionClient,
com.metamx.emitter.service.ServiceEmitter emitter,
DataSegmentPusher segmentPusher,
DataSegmentKiller dataSegmentKiller,
DataSegmentMover dataSegmentMover,
DataSegmentArchiver dataSegmentArchiver,
DataSegmentAnnouncer segmentAnnouncer,
DataSegmentServerAnnouncer serverAnnouncer,
SegmentHandoffNotifierFactory handoffNotifierFactory,
QueryRunnerFactoryConglomerate queryRunnerFactoryConglomerate,
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,
QueryRunnerFactoryConglomerate queryRunnerFactoryConglomerate,
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.