Constructor and Description |
---|
BrokerServerView(QueryToolChestWarehouse warehouse,
QueryWatcher queryWatcher,
com.fasterxml.jackson.databind.ObjectMapper smileMapper,
HttpClient httpClient,
FilteredServerInventoryView baseView,
TierSelectorStrategy tierSelectorStrategy,
ServiceEmitter emitter,
BrokerSegmentWatcherConfig segmentWatcherConfig) |
DirectDruidClient(QueryToolChestWarehouse warehouse,
QueryWatcher queryWatcher,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
HttpClient httpClient,
String scheme,
String host,
ServiceEmitter emitter) |
Modifier and Type | Method and Description |
---|---|
void |
RedisCache.doMonitor(ServiceEmitter emitter) |
void |
MemcachedCache.doMonitor(ServiceEmitter emitter) |
void |
MapCache.doMonitor(ServiceEmitter emitter) |
void |
HybridCache.doMonitor(ServiceEmitter emitter) |
void |
CaffeineCache.doMonitor(ServiceEmitter emitter) |
boolean |
CacheMonitor.doMonitor(ServiceEmitter emitter) |
void |
Cache.doMonitor(ServiceEmitter emitter)
Custom metrics not covered by CacheStats may be emitted by this method.
|
Modifier and Type | Method and Description |
---|---|
ServiceEmitter |
TaskToolbox.getEmitter() |
Constructor and Description |
---|
TaskToolbox(TaskConfig config,
TaskActionClient taskActionClient,
ServiceEmitter emitter,
DataSegmentPusher segmentPusher,
DataSegmentKiller dataSegmentKiller,
DataSegmentMover dataSegmentMover,
DataSegmentArchiver dataSegmentArchiver,
DataSegmentAnnouncer segmentAnnouncer,
DataSegmentServerAnnouncer serverAnnouncer,
SegmentHandoffNotifierFactory handoffNotifierFactory,
com.google.inject.Provider<QueryRunnerFactoryConglomerate> queryRunnerFactoryConglomerateProvider,
ExecutorService queryExecutorService,
MonitorScheduler monitorScheduler,
SegmentLoader segmentLoader,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
File taskWorkDir,
IndexIO indexIO,
Cache cache,
CacheConfig cacheConfig,
IndexMergerV9 indexMergerV9,
DruidNodeAnnouncer druidNodeAnnouncer,
DruidNode druidNode,
LookupNodeService lookupNodeService,
DataNodeService dataNodeService) |
TaskToolboxFactory(TaskConfig config,
TaskActionClientFactory taskActionClientFactory,
ServiceEmitter emitter,
DataSegmentPusher segmentPusher,
DataSegmentKiller dataSegmentKiller,
DataSegmentMover dataSegmentMover,
DataSegmentArchiver dataSegmentArchiver,
DataSegmentAnnouncer segmentAnnouncer,
DataSegmentServerAnnouncer serverAnnouncer,
SegmentHandoffNotifierFactory handoffNotifierFactory,
com.google.inject.Provider<QueryRunnerFactoryConglomerate> queryRunnerFactoryConglomerateProvider,
ExecutorService queryExecutorService,
MonitorScheduler monitorScheduler,
SegmentLoaderFactory segmentLoaderFactory,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
IndexIO indexIO,
Cache cache,
CacheConfig cacheConfig,
IndexMergerV9 indexMergerV9,
DruidNodeAnnouncer druidNodeAnnouncer,
DruidNode druidNode,
LookupNodeService lookupNodeService,
DataNodeService dataNodeService) |
Modifier and Type | Method and Description |
---|---|
ServiceEmitter |
TaskActionToolbox.getEmitter() |
Constructor and Description |
---|
TaskActionToolbox(TaskLockbox taskLockbox,
IndexerMetadataStorageCoordinator indexerMetadataStorageCoordinator,
ServiceEmitter emitter,
SupervisorManager supervisorManager) |
Modifier and Type | Method and Description |
---|---|
ServiceEmitter |
KafkaSupervisorSpec.getEmitter() |
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) |
Constructor and Description |
---|
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) |
ThreadPoolTaskRunner(TaskToolboxFactory toolboxFactory,
TaskConfig taskConfig,
ServiceEmitter emitter,
DruidNode node,
ServerConfig serverConfig) |
Modifier and Type | Method and Description |
---|---|
static void |
EmittingLogger.registerEmitter(ServiceEmitter emitter) |
Modifier and Type | Field and Description |
---|---|
protected ServiceEmitter |
AlertBuilder.emitter |
Modifier and Type | Method and Description |
---|---|
static AlertBuilder |
AlertBuilder.createEmittable(ServiceEmitter emitter,
String descriptionFormat,
Object... objects) |
Constructor and Description |
---|
AlertBuilder(String description,
ServiceEmitter emitter) |
Modifier and Type | Method and Description |
---|---|
boolean |
SysMonitor.doMonitor(ServiceEmitter emitter) |
boolean |
ParametrizedUriEmitterMonitor.doMonitor(ServiceEmitter emitter) |
boolean |
MonitorOfTheMonitors.doMonitor(ServiceEmitter emitter) |
boolean |
JvmThreadsMonitor.doMonitor(ServiceEmitter emitter) |
boolean |
JvmMonitor.doMonitor(ServiceEmitter emitter) |
boolean |
JvmCpuMonitor.doMonitor(ServiceEmitter emitter) |
boolean |
HttpPostEmitterMonitor.doMonitor(ServiceEmitter emitter) |
boolean |
CpuAcctDeltaMonitor.doMonitor(ServiceEmitter emitter) |
abstract boolean |
AbstractMonitor.doMonitor(ServiceEmitter emitter) |
boolean |
Monitor.monitor(ServiceEmitter emitter) |
boolean |
CompoundMonitor.monitor(ServiceEmitter emitter) |
boolean |
AbstractMonitor.monitor(ServiceEmitter emitter) |
Constructor and Description |
---|
MonitorScheduler(MonitorSchedulerConfig config,
ScheduledExecutorService exec,
ServiceEmitter emitter,
List<Monitor> monitors) |
Modifier and Type | Method and Description |
---|---|
boolean |
ExecutorServiceMonitor.doMonitor(ServiceEmitter emitter) |
void |
QueryMetrics.emit(ServiceEmitter emitter)
Emits all metrics, registered since the last
emit() call on this QueryMetrics object. |
void |
DefaultQueryMetrics.emit(ServiceEmitter emitter) |
FluentQueryRunnerBuilder.FluentQueryRunner |
FluentQueryRunnerBuilder.FluentQueryRunner.emitCPUTimeMetric(ServiceEmitter emitter) |
void |
MetricsEmittingExecutorService.emitMetrics(ServiceEmitter emitter,
ServiceMetricEvent.Builder metricBuilder) |
void |
ExecutorServiceMonitor.MetricEmitter.emitMetrics(ServiceEmitter emitter,
ServiceMetricEvent.Builder metricBuilder) |
static <T> QueryRunner<T> |
CPUTimeMetricQueryRunner.safeBuild(QueryRunner<T> delegate,
QueryToolChest<T,? extends Query<T>> queryToolChest,
ServiceEmitter emitter,
AtomicLong accumulator,
boolean report) |
Constructor and Description |
---|
IntervalChunkingQueryRunner(QueryRunner<T> baseRunner,
QueryToolChest<T,Query<T>> toolChest,
ExecutorService executor,
QueryWatcher queryWatcher,
ServiceEmitter emitter) |
IntervalChunkingQueryRunnerDecorator(ExecutorService executor,
QueryWatcher queryWatcher,
ServiceEmitter emitter) |
MetricsEmittingQueryRunner(ServiceEmitter emitter,
QueryToolChest<T,? extends Query<T>> queryToolChest,
QueryRunner<T> queryRunner,
ObjLongConsumer<? super QueryMetrics<?>> reportMetric,
Consumer<QueryMetrics<?>> applyCustomDimensions) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultSearchQueryMetrics.emit(ServiceEmitter emitter) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultSelectQueryMetrics.emit(ServiceEmitter emitter) |
Modifier and Type | Method and Description |
---|---|
boolean |
RealtimeMetricsMonitor.doMonitor(ServiceEmitter emitter) |
Modifier and Type | Method and Description |
---|---|
static Appenderator |
Appenderators.createRealtime(DataSchema schema,
AppenderatorConfig config,
FireDepartmentMetrics metrics,
DataSegmentPusher dataSegmentPusher,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
IndexIO indexIO,
IndexMerger indexMerger,
QueryRunnerFactoryConglomerate conglomerate,
DataSegmentAnnouncer segmentAnnouncer,
ServiceEmitter emitter,
ExecutorService queryExecutorService,
Cache cache,
CacheConfig cacheConfig) |
Constructor and Description |
---|
AppenderatorImpl(DataSchema schema,
AppenderatorConfig tuningConfig,
FireDepartmentMetrics metrics,
DataSegmentPusher dataSegmentPusher,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
QueryRunnerFactoryConglomerate conglomerate,
DataSegmentAnnouncer segmentAnnouncer,
ServiceEmitter emitter,
ExecutorService queryExecutorService,
IndexIO indexIO,
IndexMerger indexMerger,
Cache cache,
CacheConfig cacheConfig) |
DefaultRealtimeAppenderatorFactory(ServiceEmitter emitter,
QueryRunnerFactoryConglomerate conglomerate,
DataSegmentAnnouncer segmentAnnouncer,
ExecutorService queryExecutorService,
DataSegmentPusher dataSegmentPusher,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
IndexIO indexIO,
IndexMerger indexMerger,
Cache cache,
CacheConfig cacheConfig) |
SinkQuerySegmentWalker(String dataSource,
VersionedIntervalTimeline<String,Sink> sinkTimeline,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
ServiceEmitter emitter,
QueryRunnerFactoryConglomerate conglomerate,
ExecutorService queryExecutorService,
Cache cache,
CacheConfig cacheConfig) |
Constructor and Description |
---|
FlushingPlumber(org.joda.time.Duration flushDuration,
DataSchema schema,
RealtimeTuningConfig config,
FireDepartmentMetrics metrics,
ServiceEmitter emitter,
QueryRunnerFactoryConglomerate conglomerate,
DataSegmentAnnouncer segmentAnnouncer,
ExecutorService queryExecutorService,
IndexMerger indexMerger,
IndexIO indexIO,
Cache cache,
CacheConfig cacheConfig,
com.fasterxml.jackson.databind.ObjectMapper objectMapper) |
FlushingPlumberSchool(org.joda.time.Duration flushDuration,
ServiceEmitter emitter,
QueryRunnerFactoryConglomerate conglomerate,
DataSegmentAnnouncer segmentAnnouncer,
ExecutorService queryExecutorService,
IndexMergerV9 indexMergerV9,
IndexIO indexIO,
Cache cache,
CacheConfig cacheConfig,
com.fasterxml.jackson.databind.ObjectMapper objectMapper) |
RealtimePlumber(DataSchema schema,
RealtimeTuningConfig config,
FireDepartmentMetrics metrics,
ServiceEmitter emitter,
QueryRunnerFactoryConglomerate conglomerate,
DataSegmentAnnouncer segmentAnnouncer,
ExecutorService queryExecutorService,
DataSegmentPusher dataSegmentPusher,
SegmentPublisher segmentPublisher,
SegmentHandoffNotifier handoffNotifier,
IndexMerger indexMerger,
IndexIO indexIO,
Cache cache,
CacheConfig cacheConfig,
com.fasterxml.jackson.databind.ObjectMapper objectMapper) |
RealtimePlumberSchool(ServiceEmitter emitter,
QueryRunnerFactoryConglomerate conglomerate,
DataSegmentPusher dataSegmentPusher,
DataSegmentAnnouncer segmentAnnouncer,
SegmentPublisher segmentPublisher,
SegmentHandoffNotifierFactory handoffNotifierFactory,
ExecutorService executorService,
IndexMergerV9 indexMergerV9,
IndexIO indexIO,
Cache cache,
CacheConfig cacheConfig,
com.fasterxml.jackson.databind.ObjectMapper objectMapper) |
Constructor and Description |
---|
AsyncQueryForwardingServlet(QueryToolChestWarehouse warehouse,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
com.fasterxml.jackson.databind.ObjectMapper smileMapper,
QueryHostFinder hostFinder,
com.google.inject.Provider<org.eclipse.jetty.client.HttpClient> httpClientProvider,
DruidHttpClientConfig httpClientConfig,
ServiceEmitter emitter,
RequestLogger requestLogger,
GenericQueryMetricsFactory queryMetricsFactory) |
ClientQuerySegmentWalker(ServiceEmitter emitter,
CachingClusteredClient baseClient,
QueryToolChestWarehouse warehouse,
RetryQueryRunnerConfig retryConfig,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
ServerConfig serverConfig) |
QueryLifecycle(QueryToolChestWarehouse warehouse,
QuerySegmentWalker texasRanger,
GenericQueryMetricsFactory queryMetricsFactory,
ServiceEmitter emitter,
RequestLogger requestLogger,
AuthorizerMapper authorizerMapper,
long startMs,
long startNs) |
QueryLifecycleFactory(QueryToolChestWarehouse warehouse,
QuerySegmentWalker texasRanger,
GenericQueryMetricsFactory queryMetricsFactory,
ServiceEmitter emitter,
RequestLogger requestLogger,
AuthConfig authConfig,
AuthorizerMapper authorizerMapper) |
Constructor and Description |
---|
SQLAuditManager(SQLMetadataConnector connector,
com.google.common.base.Supplier<MetadataStorageTablesConfig> dbTables,
ServiceEmitter emitter,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
SQLAuditManagerConfig config) |
SQLAuditManagerProvider(com.google.common.base.Supplier<MetadataStorageTablesConfig> dbTables,
SQLMetadataConnector connector,
Lifecycle lifecycle,
ServiceEmitter emitter,
com.fasterxml.jackson.databind.ObjectMapper mapper,
SQLAuditManagerConfig config) |
Constructor and Description |
---|
ServerManager(QueryRunnerFactoryConglomerate conglomerate,
ServiceEmitter emitter,
ExecutorService exec,
ExecutorService cachingExec,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
Cache cache,
CacheConfig cacheConfig,
SegmentManager segmentManager,
ServerConfig serverConfig) |
Modifier and Type | Method and Description |
---|---|
ServiceEmitter |
DruidCoordinatorRuntimeParams.getEmitter() |
Modifier and Type | Method and Description |
---|---|
DruidCoordinatorRuntimeParams.Builder |
DruidCoordinatorRuntimeParams.Builder.withEmitter(ServiceEmitter emitter) |
Constructor and Description |
---|
DruidCoordinator(DruidCoordinatorConfig config,
ZkPathsConfig zkPaths,
JacksonConfigManager configManager,
MetadataSegmentManager metadataSegmentManager,
ServerInventoryView serverInventoryView,
MetadataRuleManager metadataRuleManager,
org.apache.curator.framework.CuratorFramework curator,
ServiceEmitter emitter,
ScheduledExecutorFactory scheduledExecutorFactory,
IndexingServiceClient indexingServiceClient,
LoadQueueTaskMaster taskMaster,
ServiceAnnouncer serviceAnnouncer,
DruidNode self,
Set<DruidCoordinatorHelper> indexingServiceHelpers,
BalancerStrategyFactory factory,
LookupCoordinatorManager lookupCoordinatorManager,
DruidLeaderSelector coordLeaderSelector) |
Modifier and Type | Method and Description |
---|---|
ServiceEmitter |
EmitterModule.getServiceEmitter(com.google.common.base.Supplier<DruidNode> configSupplier,
Emitter emitter,
Map<String,String> extraServiceDimensions) |
Modifier and Type | Method and Description |
---|---|
boolean |
HttpEmittingMonitor.doMonitor(ServiceEmitter serviceEmitter) |
Modifier and Type | Method and Description |
---|---|
boolean |
JettyServerModule.JettyMonitor.doMonitor(ServiceEmitter emitter) |
Constructor and Description |
---|
EmittingRequestLogger(ServiceEmitter emitter,
String feed) |
Constructor and Description |
---|
CacheScheduler(ServiceEmitter serviceEmitter,
Map<Class<? extends ExtractionNamespace>,CacheGenerator<?>> namespaceGeneratorMap,
NamespaceExtractionCacheManager cacheManager) |
NamespaceExtractionCacheManager(Lifecycle lifecycle,
ServiceEmitter serviceEmitter,
NamespaceExtractionConfig config) |
OffHeapNamespaceExtractionCacheManager(Lifecycle lifecycle,
ServiceEmitter serviceEmitter,
NamespaceExtractionConfig config) |
OnHeapNamespaceExtractionCacheManager(Lifecycle lifecycle,
ServiceEmitter serviceEmitter,
NamespaceExtractionConfig config) |
Modifier and Type | Method and Description |
---|---|
boolean |
QueryCountStatsMonitor.doMonitor(ServiceEmitter emitter) |
boolean |
HistoricalMetricsMonitor.doMonitor(ServiceEmitter emitter) |
boolean |
EventReceiverFirehoseMonitor.doMonitor(ServiceEmitter emitter) |
MonitorScheduler |
MetricsModule.getMonitorScheduler(com.google.common.base.Supplier<DruidMonitorSchedulerConfig> config,
MonitorsConfig monitorsConfig,
Set<Class<? extends Monitor>> monitorSet,
ServiceEmitter emitter,
com.google.inject.Injector injector) |
Modifier and Type | Method and Description |
---|---|
boolean |
AvaticaMonitor.doMonitor(ServiceEmitter emitter) |
Modifier and Type | Method and Description |
---|---|
ServiceEmitter |
DruidTestModule.getServiceEmitter(com.google.common.base.Supplier<LoggingEmitterConfig> config,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
Copyright © 2011–2018. All rights reserved.