Constructor and Description |
---|
MetadataStoreBasedUsedSegmentLister(IndexerMetadataStorageCoordinator indexerMetadataStorageCoordinator) |
Modifier and Type | Method and Description |
---|---|
IndexerMetadataStorageCoordinator |
TaskActionToolbox.getIndexerMetadataStorageCoordinator() |
Constructor and Description |
---|
TaskActionToolbox(TaskLockbox taskLockbox,
IndexerMetadataStorageCoordinator indexerMetadataStorageCoordinator,
ServiceEmitter emitter,
SupervisorManager supervisorManager) |
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) |
Constructor and Description |
---|
IndexerMetadataStorageAdapter(TaskStorageQueryAdapter taskStorageQueryAdapter,
IndexerMetadataStorageCoordinator indexerMetadataStorageCoordinator) |
Modifier and Type | Class and Description |
---|---|
class |
IndexerSQLMetadataStorageCoordinator |
Constructor and Description |
---|
MetadataResource(MetadataSegmentManager metadataSegmentManager,
IndexerMetadataStorageCoordinator metadataStorageCoordinator,
AuthConfig authConfig,
AuthorizerMapper authorizerMapper) |
Copyright © 2011–2018. All rights reserved.