Uses of Interface
io.druid.indexing.overlord.TaskStorage

Packages that use TaskStorage

Package	Description
io.druid.indexing.common.actions
io.druid.indexing.kafka.supervisor
io.druid.indexing.overlord

Uses of TaskStorage in io.druid.indexing.common.actions

Constructors in io.druid.indexing.common.actions with parameters of type TaskStorage

Constructor and Description
LocalTaskActionClient(Task task, TaskStorage storage, TaskActionToolbox toolbox)
LocalTaskActionClientFactory(TaskStorage storage, TaskActionToolbox toolbox)

Uses of TaskStorage in io.druid.indexing.kafka.supervisor

Constructors in io.druid.indexing.kafka.supervisor with parameters of type TaskStorage

Constructor and Description
KafkaSupervisor(TaskStorage taskStorage, TaskMaster taskMaster, IndexerMetadataStorageCoordinator indexerMetadataStorageCoordinator, KafkaIndexTaskClientFactory taskClientFactory, com.fasterxml.jackson.databind.ObjectMapper mapper, KafkaSupervisorSpec spec)
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)

Uses of TaskStorage in io.druid.indexing.overlord

Classes in io.druid.indexing.overlord that implement TaskStorage

Modifier and Type	Class and Description
class	HeapMemoryTaskStorage Implements an in-heap TaskStorage facility, with no persistence across restarts.
class	MetadataTaskStorage

Constructors in io.druid.indexing.overlord with parameters of type TaskStorage

Constructor and Description
TaskLockbox(TaskStorage taskStorage)
TaskMaster(TaskQueueConfig taskQueueConfig, TaskLockbox taskLockbox, TaskStorage taskStorage, TaskActionClientFactory taskActionClientFactory, DruidNode selfNode, TaskRunnerFactory runnerFactory, ServiceAnnouncer serviceAnnouncer, CoordinatorOverlordServiceConfig coordinatorOverlordServiceConfig, ServiceEmitter emitter, SupervisorManager supervisorManager, OverlordHelperManager overlordHelperManager, DruidLeaderSelector overlordLeaderSelector)
TaskQueue(TaskQueueConfig config, TaskStorage taskStorage, TaskRunner taskRunner, TaskActionClientFactory taskActionClientFactory, TaskLockbox taskLockbox, ServiceEmitter emitter)
TaskStorageQueryAdapter(TaskStorage storage)