public class KafkaSupervisorSpec extends Object implements SupervisorSpec
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 |
---|---|
Supervisor |
createSupervisor() |
Map<String,Object> |
getContext() |
DataSchema |
getDataSchema() |
List<String> |
getDataSources() |
ServiceEmitter |
getEmitter() |
String |
getId() |
KafkaSupervisorIOConfig |
getIoConfig() |
DruidMonitorSchedulerConfig |
getMonitorSchedulerConfig() |
KafkaSupervisorTuningConfig |
getTuningConfig() |
String |
toString() |
public 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)
public DataSchema getDataSchema()
public KafkaSupervisorTuningConfig getTuningConfig()
public KafkaSupervisorIOConfig getIoConfig()
public ServiceEmitter getEmitter()
public String getId()
getId
in interface SupervisorSpec
public DruidMonitorSchedulerConfig getMonitorSchedulerConfig()
public Supervisor createSupervisor()
createSupervisor
in interface SupervisorSpec
public List<String> getDataSources()
getDataSources
in interface SupervisorSpec
Copyright © 2011–2018. All rights reserved.