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

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	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	Description
static WorkerMetricsProcessor	MetricStoreConfig.configureMetricProcessor(Map conf)	Configures metric processor (running on supervisor) to use the class specified in the conf.