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,
ServiceEmitter emitter,
DruidMonitorSchedulerConfig monitorSchedulerConfig) |
Modifier and Type | Method and Description |
---|---|
MonitorScheduler |
MetricsModule.getMonitorScheduler(com.google.common.base.Supplier<DruidMonitorSchedulerConfig> config,
MonitorsConfig monitorsConfig,
Set<Class<? extends Monitor>> monitorSet,
ServiceEmitter emitter,
com.google.inject.Injector injector) |
Copyright © 2011–2018. All rights reserved.