## Uses of Class
org.apache.storm.metrics2.StormMetricRegistry

- Packages that use StormMetricRegistry
  Package | Description
  --- | ---
  org.apache.storm.daemon.worker |
  org.apache.storm.messaging |
  org.apache.storm.messaging.netty |
  org.apache.storm.metrics2 |
  org.apache.storm.task |
  org.apache.storm.utils |

- - ### Uses of StormMetricRegistry in org.apache.storm.daemon.worker

    Methods in org.apache.storm.daemon.worker that return StormMetricRegistry
    Modifier and Type | Method and Description
    --- | ---
    `StormMetricRegistry` | WorkerState.`getMetricRegistry()`

    Constructors in org.apache.storm.daemon.worker with parameters of type StormMetricRegistry
    Constructor and Description
    `BackPressureTracker(String workerId, Map<Integer,JCQueue> localTasksToQueues, StormMetricRegistry metricRegistry, Map<Integer,String> taskToComponent)`
    `WorkerState(Map<String,Object> conf, IContext mqContext, String topologyId, String assignmentId, Supplier<SupervisorIfaceFactory> supervisorIfaceSupplier, int port, String workerId, Map<String,Object> topologyConf, IStateStorage stateStorage, IStormClusterState stormClusterState, Collection<IAutoCredentials> autoCredentials, StormMetricRegistry metricRegistry, Credentials initialCredentials)`

  - ### Uses of StormMetricRegistry in org.apache.storm.messaging

    Methods in org.apache.storm.messaging with parameters of type StormMetricRegistry
    Modifier and Type | Method and Description
    --- | ---
    `static IContext` | TransportFactory.`makeContext(Map<String,Object> topoConf, StormMetricRegistry metricRegistry)`
    `default void` | IContext.`prepare(Map<String,Object> topoConf, StormMetricRegistry metricRegistry)` This method is invoked at the startup of messaging plugin.

  - ### Uses of StormMetricRegistry in org.apache.storm.messaging.netty

    Methods in org.apache.storm.messaging.netty with parameters of type StormMetricRegistry
    Modifier and Type | Method and Description
    --- | ---
    `void` | Context.`prepare(Map<String,Object> topoConf, StormMetricRegistry metricRegistry)`

  - ### Uses of StormMetricRegistry in org.apache.storm.metrics2

    Constructors in org.apache.storm.metrics2 with parameters of type StormMetricRegistry
    Constructor and Description
    `TaskMetricDimensions(int taskId, String componentId, String streamId, StormMetricRegistry metricRegistry)`
    `TaskMetrics(WorkerTopologyContext context, String componentId, Integer taskid, StormMetricRegistry metricRegistry, Map<String,Object> topoConf)`

  - ### Uses of StormMetricRegistry in org.apache.storm.task

    Constructors in org.apache.storm.task with parameters of type StormMetricRegistry
    Constructor and Description
    `TopologyContext(StormTopology topology, Map<String,Object> topoConf, Map<Integer,String> taskToComponent, Map<String,List<Integer>> componentToSortedTasks, Map<String,Map<String,Fields>> componentToStreamToFields, Map<String,Long> blobToLastKnownVersionShared, String stormId, String codeDir, String pidDir, Integer taskId, Integer workerPort, List<Integer> workerTasks, Map<String,Object> defaultResources, Map<String,Object> userResources, Map<String,Object> executorData, Map<Integer,Map<Integer,Map<String,IMetric>>> registeredMetrics, AtomicBoolean openOrPrepareWasCalled, StormMetricRegistry metricRegistry)`

  - ### Uses of StormMetricRegistry in org.apache.storm.utils

    Constructors in org.apache.storm.utils with parameters of type StormMetricRegistry
    Constructor and Description
    `JCQueue(String queueName, String metricNamePrefix, int size, int overflowLimit, int producerBatchSz, IWaitStrategy backPressureWaitStrategy, String topologyId, String componentId, List<Integer> taskIds, int port, StormMetricRegistry metricRegistry)`
    `JCQueueMetrics(String metricNamePrefix, String topologyId, String componentId, int taskId, int port, StormMetricRegistry metricRegistry, org.apache.storm.shade.org.jctools.queues.MpscArrayQueue<Object> receiveQ, org.apache.storm.shade.org.jctools.queues.MpscUnboundedArrayQueue<Object> overflowQ)`

Copyright © 2021 The Apache Software Foundation. All rights reserved.