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)

Method Summary

Modifier and Type	Method and Description
Supervisor	createSupervisor()
Map<String,Object>	getContext()
DataSchema	getDataSchema()
String	getId()
KafkaSupervisorIOConfig	getIoConfig()
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)

Method Detail

getDataSchema

public DataSchema getDataSchema()

getTuningConfig

public KafkaSupervisorTuningConfig getTuningConfig()

getIoConfig

public KafkaSupervisorIOConfig getIoConfig()

getContext

public Map<String,Object> getContext()

getId

public String getId()

Specified by:

getId in interface SupervisorSpec

createSupervisor

public Supervisor createSupervisor()

Specified by:

createSupervisor in interface SupervisorSpec

toString

public String toString()

Overrides:

toString in class Object