| Modifier and Type | Field and Description | 
|---|---|
| protected Map<String,IMetric> | BuiltinMetrics. metricMap | 
| Modifier and Type | Method and Description | 
|---|---|
| static void | BuiltinMetricsUtil. registerMetric(String name,
              IMetric metric,
              Map<String,Object> topoConf,
              TopologyContext context) | 
| Modifier and Type | Field and Description | 
|---|---|
| protected Map<Integer,Map<Integer,Map<String,IMetric>>> | Executor. intervalToTaskToMetricToRegistry | 
| Modifier and Type | Method and Description | 
|---|---|
| Map<Integer,Map<Integer,Map<String,IMetric>>> | Executor. getIntervalToTaskToMetricToRegistry() | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | KafkaOffsetMetric<K,V>This class is used compute the partition and topic level offset metrics. | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | DeserializingConnectionCallbackA class that is called when a TaskMessage arrives. | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | AssignableMetric | 
| class  | CombinedMetric | 
| class  | CountMetric | 
| class  | MultiCountMetric | 
| class  | MultiReducedMetric | 
| class  | ReducedMetric | 
| class  | StateMetric | 
| Modifier and Type | Interface and Description | 
|---|---|
| interface  | IShellMetric | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | AssignableShellMetric | 
| class  | CombinedShellMetric | 
| class  | CountShellMetric | 
| class  | ReducedShellMetric | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | CGroupCpuReport CPU used in the cgroup. | 
| class  | CGroupCpuGuaranteeReport the guaranteed number of ms this worker has requested. | 
| class  | CGroupMemoryLimitReports the current memory limit of the cgroup for this worker. | 
| class  | CGroupMemoryUsageReports the current memory usage of the cgroup for this worker. | 
| class  | CGroupMetricsBase<T>Base class for checking if CGroups are enabled, etc. | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | CountStatAndMetricActs as a Count Metric, but also keeps track of approximate counts for the last 10 mins, 3 hours, 1 day, and all time. | 
| class  | LatencyStatAndMetricActs as a Latency Metric, but also keeps track of approximate latency for the last 10 mins, 3 hours, 1 day, and all time. | 
| class  | MultiCountStatAndMetric<T>Acts as a MultiCount Metric, but keeps track of approximate counts for the last 10 mins, 3 hours, 1 day, and all time. | 
| class  | MultiLatencyStatAndMetric<T>Acts as a Latnecy Metric for multiple keys, but keeps track of approximate counts for the last 10 mins, 3 hours, 1 day, and all time. | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | HistogramMetricA metric wrapping an HdrHistogram. | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | CPUMetricA metric using Sigar to get User and System CPU utilization for a worker. | 
| Modifier and Type | Method and Description | 
|---|---|
| <T extends IMetric> | IMetricsContext. registerMetric(String name,
              T metric,
              int timeBucketSizeInSecs)Deprecated. 
 in favor of metrics v2 (the non-deprecated methods on this class) | 
| <T extends IMetric> | TopologyContext. registerMetric(String name,
              T metric,
              int timeBucketSizeInSecs)Deprecated.  | 
| Modifier and Type | Method and Description | 
|---|---|
| IMetric | TopologyContext. getRegisteredMetricByName(String name)Deprecated.  | 
| 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) | 
| Modifier and Type | Method and Description | 
|---|---|
| <T extends IMetric> | TridentOperationContext. registerMetric(String name,
              T metric,
              int timeBucketSizeInSecs) | 
Copyright © 2022 The Apache Software Foundation. All rights reserved.