| Package | Description |
|---|---|
| io.druid.indexing.kafka.supervisor | |
| io.druid.server.metrics |
| Modifier and Type | Method and Description |
|---|---|
DruidMonitorSchedulerConfig |
KafkaSupervisorSpec.getMonitorSchedulerConfig() |
| Constructor and Description |
|---|
KafkaSupervisorSpec(DataSchema dataSchema,
KafkaSupervisorTuningConfig tuningConfig,
KafkaSupervisorIOConfig ioConfig,
Map<String,Object> context,
TaskStorage taskStorage,
TaskMaster taskMaster,
IndexerMetadataStorageCoordinator indexerMetadataStorageCoordinator,
KafkaIndexTaskClientFactory kafkaIndexTaskClientFactory,
com.fasterxml.jackson.databind.ObjectMapper mapper,
com.metamx.emitter.service.ServiceEmitter emitter,
DruidMonitorSchedulerConfig monitorSchedulerConfig) |
| Modifier and Type | Method and Description |
|---|---|
com.metamx.metrics.MonitorScheduler |
MetricsModule.getMonitorScheduler(com.google.common.base.Supplier<DruidMonitorSchedulerConfig> config,
MonitorsConfig monitorsConfig,
Set<Class<? extends com.metamx.metrics.Monitor>> monitorSet,
com.metamx.emitter.service.ServiceEmitter emitter,
com.google.inject.Injector injector) |
Copyright © 2011–2017. All rights reserved.