io.druid.indexing.kafka.supervisor

Class KafkaSupervisorSpec

java.lang.Object

io.druid.indexing.kafka.supervisor.KafkaSupervisorSpec

All Implemented Interfaces:

SupervisorSpec

public class KafkaSupervisorSpec
extends Object
implements SupervisorSpec

Constructor Summary

Constructors

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)

Method Summary

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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

KafkaSupervisorSpec

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)

Method Detail

getDataSchema

public DataSchema getDataSchema()

getTuningConfig

public KafkaSupervisorTuningConfig getTuningConfig()

getIoConfig

public KafkaSupervisorIOConfig getIoConfig()

getContext

public Map<String,Object> getContext()

getEmitter

public ServiceEmitter getEmitter()

getId

public String getId()

Specified by:

getId in interface SupervisorSpec

getMonitorSchedulerConfig

public DruidMonitorSchedulerConfig getMonitorSchedulerConfig()

createSupervisor

public Supervisor createSupervisor()

Specified by:

createSupervisor in interface SupervisorSpec

getDataSources

public List<String> getDataSources()

Specified by:

getDataSources in interface SupervisorSpec

toString

public String toString()

Overrides:

toString in class Object