Uses of Interface
org.apache.storm.metricstore.WorkerMetricsProcessor
Packages that use WorkerMetricsProcessor
-
Uses of WorkerMetricsProcessor in org.apache.storm.daemon.supervisor
Constructors in org.apache.storm.daemon.supervisor with parameters of type WorkerMetricsProcessorModifierConstructorDescriptionSlot
(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 WorkerMetricsProcessorModifier and TypeClassDescriptionclass
Implementation of WorkerMetricsProcessor that sends metric data to Nimbus for processing.Methods in org.apache.storm.metricstore that return WorkerMetricsProcessorModifier and TypeMethodDescriptionstatic WorkerMetricsProcessor
MetricStoreConfig.configureMetricProcessor
(Map conf) Configures metric processor (running on supervisor) to use the class specified in the conf.