Uses of Class
io.druid.java.util.emitter.service.ServiceEmitter

Packages that use ServiceEmitter

Package	Description
io.druid.client
io.druid.client.cache
io.druid.indexing.common
io.druid.indexing.common.actions
io.druid.indexing.kafka.supervisor
io.druid.indexing.overlord
io.druid.java.util.emitter
io.druid.java.util.emitter.service
io.druid.java.util.metrics
io.druid.query
io.druid.query.search
io.druid.query.select
io.druid.segment.realtime
io.druid.segment.realtime.appenderator
io.druid.segment.realtime.plumber
io.druid.server
io.druid.server.audit
io.druid.server.coordination
io.druid.server.coordinator
io.druid.server.emitter
io.druid.server.initialization.jetty
io.druid.server.log
io.druid.server.lookup.namespace.cache
io.druid.server.metrics
io.druid.sql.avatica
io.druid.testing.guice

Uses of ServiceEmitter in io.druid.client

Constructors in io.druid.client with parameters of type ServiceEmitter

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)

Uses of ServiceEmitter in io.druid.client.cache

Methods in io.druid.client.cache with parameters of type ServiceEmitter

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.

Uses of ServiceEmitter in io.druid.indexing.common

Methods in io.druid.indexing.common that return ServiceEmitter

Modifier and Type	Method and Description
ServiceEmitter	TaskToolbox.getEmitter()

Constructors in io.druid.indexing.common with parameters of type ServiceEmitter

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)

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

Methods in io.druid.indexing.common.actions that return ServiceEmitter

Modifier and Type	Method and Description
ServiceEmitter	TaskActionToolbox.getEmitter()

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

Constructor and Description
TaskActionToolbox(TaskLockbox taskLockbox, IndexerMetadataStorageCoordinator indexerMetadataStorageCoordinator, ServiceEmitter emitter, SupervisorManager supervisorManager)

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

Methods in io.druid.indexing.kafka.supervisor that return ServiceEmitter

Modifier and Type	Method and Description
ServiceEmitter	KafkaSupervisorSpec.getEmitter()

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

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)

Uses of ServiceEmitter in io.druid.indexing.overlord

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

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)

Uses of ServiceEmitter in io.druid.java.util.emitter

Methods in io.druid.java.util.emitter with parameters of type ServiceEmitter

Modifier and Type	Method and Description
static void	EmittingLogger.registerEmitter(ServiceEmitter emitter)

Uses of ServiceEmitter in io.druid.java.util.emitter.service

Fields in io.druid.java.util.emitter.service declared as ServiceEmitter

Modifier and Type	Field and Description
protected ServiceEmitter	AlertBuilder.emitter

Methods in io.druid.java.util.emitter.service with parameters of type ServiceEmitter

Modifier and Type	Method and Description
static AlertBuilder	AlertBuilder.createEmittable(ServiceEmitter emitter, String descriptionFormat, Object... objects)

Constructors in io.druid.java.util.emitter.service with parameters of type ServiceEmitter

Constructor and Description
AlertBuilder(String description, ServiceEmitter emitter)

Uses of ServiceEmitter in io.druid.java.util.metrics

Methods in io.druid.java.util.metrics with parameters of type ServiceEmitter

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)

Constructors in io.druid.java.util.metrics with parameters of type ServiceEmitter

Constructor and Description
MonitorScheduler(MonitorSchedulerConfig config, ScheduledExecutorService exec, ServiceEmitter emitter, List<Monitor> monitors)

Uses of ServiceEmitter in io.druid.query

Methods in io.druid.query with parameters of type ServiceEmitter

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)

Constructors in io.druid.query with parameters of type ServiceEmitter

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)

Uses of ServiceEmitter in io.druid.query.search

Methods in io.druid.query.search with parameters of type ServiceEmitter

Modifier and Type	Method and Description
void	DefaultSearchQueryMetrics.emit(ServiceEmitter emitter)

Uses of ServiceEmitter in io.druid.query.select

Methods in io.druid.query.select with parameters of type ServiceEmitter

Modifier and Type	Method and Description
void	DefaultSelectQueryMetrics.emit(ServiceEmitter emitter)

Uses of ServiceEmitter in io.druid.segment.realtime

Methods in io.druid.segment.realtime with parameters of type ServiceEmitter

Modifier and Type	Method and Description
boolean	RealtimeMetricsMonitor.doMonitor(ServiceEmitter emitter)

Uses of ServiceEmitter in io.druid.segment.realtime.appenderator

Methods in io.druid.segment.realtime.appenderator with parameters of type ServiceEmitter

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)

Constructors in io.druid.segment.realtime.appenderator with parameters of type ServiceEmitter

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)

Uses of ServiceEmitter in io.druid.segment.realtime.plumber

Constructors in io.druid.segment.realtime.plumber with parameters of type ServiceEmitter

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)

Uses of ServiceEmitter in io.druid.server

Constructors in io.druid.server with parameters of type ServiceEmitter

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)

Uses of ServiceEmitter in io.druid.server.audit

Constructors in io.druid.server.audit with parameters of type ServiceEmitter

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)

Uses of ServiceEmitter in io.druid.server.coordination

Constructors in io.druid.server.coordination with parameters of type ServiceEmitter

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)

Uses of ServiceEmitter in io.druid.server.coordinator

Methods in io.druid.server.coordinator that return ServiceEmitter

Modifier and Type	Method and Description
ServiceEmitter	DruidCoordinatorRuntimeParams.getEmitter()

Methods in io.druid.server.coordinator with parameters of type ServiceEmitter

Modifier and Type	Method and Description
DruidCoordinatorRuntimeParams.Builder	DruidCoordinatorRuntimeParams.Builder.withEmitter(ServiceEmitter emitter)

Constructors in io.druid.server.coordinator with parameters of type ServiceEmitter

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)

Uses of ServiceEmitter in io.druid.server.emitter

Methods in io.druid.server.emitter that return ServiceEmitter

Modifier and Type	Method and Description
ServiceEmitter	EmitterModule.getServiceEmitter(com.google.common.base.Supplier<DruidNode> configSupplier, Emitter emitter, Map<String,String> extraServiceDimensions)

Methods in io.druid.server.emitter with parameters of type ServiceEmitter

Modifier and Type	Method and Description
boolean	HttpEmittingMonitor.doMonitor(ServiceEmitter serviceEmitter)

Uses of ServiceEmitter in io.druid.server.initialization.jetty

Methods in io.druid.server.initialization.jetty with parameters of type ServiceEmitter

Modifier and Type	Method and Description
boolean	JettyServerModule.JettyMonitor.doMonitor(ServiceEmitter emitter)

Uses of ServiceEmitter in io.druid.server.log

Constructors in io.druid.server.log with parameters of type ServiceEmitter

Constructor and Description
EmittingRequestLogger(ServiceEmitter emitter, String feed)

Uses of ServiceEmitter in io.druid.server.lookup.namespace.cache

Constructors in io.druid.server.lookup.namespace.cache with parameters of type ServiceEmitter

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)

Uses of ServiceEmitter in io.druid.server.metrics

Methods in io.druid.server.metrics with parameters of type ServiceEmitter

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)

Uses of ServiceEmitter in io.druid.sql.avatica

Methods in io.druid.sql.avatica with parameters of type ServiceEmitter

Modifier and Type	Method and Description
boolean	AvaticaMonitor.doMonitor(ServiceEmitter emitter)

Uses of ServiceEmitter in io.druid.testing.guice

Methods in io.druid.testing.guice that return ServiceEmitter

Modifier and Type	Method and Description
ServiceEmitter	DruidTestModule.getServiceEmitter(com.google.common.base.Supplier<LoggingEmitterConfig> config, com.fasterxml.jackson.databind.ObjectMapper jsonMapper)