Uses of Interface
org.apache.storm.metricstore.WorkerMetricsProcessor

Packages that use WorkerMetricsProcessor

Package	Description
org.apache.storm.daemon.supervisor
org.apache.storm.metricstore

Uses of WorkerMetricsProcessor in org.apache.storm.daemon.supervisor

Constructors in org.apache.storm.daemon.supervisor with parameters of type WorkerMetricsProcessor

Constructor and Description

Slot(AsyncLocalizer localizer, Map<String,Object> conf, ContainerLauncher containerLauncher, String host, int port, LocalState localState, IStormClusterState clusterState, ISupervisor supervisor, AtomicReference<Map<Long,LocalAssignment>> cachedCurrentAssignments, OnlyLatestExecutor<Integer> metricsExec, WorkerMetricsProcessor metricsProcessor, org.apache.storm.daemon.supervisor.SlotMetrics slotMetrics)

Uses of WorkerMetricsProcessor in org.apache.storm.metricstore

Classes in org.apache.storm.metricstore that implement WorkerMetricsProcessor

Modifier and Type	Class and Description
class	NimbusMetricProcessor Implementation of WorkerMetricsProcessor that sends metric data to Nimbus for processing.

Methods in org.apache.storm.metricstore that return WorkerMetricsProcessor

Modifier and Type	Method and Description
static WorkerMetricsProcessor	MetricStoreConfig.configureMetricProcessor(Map conf) Configures metric processor (running on supervisor) to use the class specified in the conf.