Modifier and Type | Class and Description |
---|---|
static class |
KafkaUtils.KafkaOffsetMetric |
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 |
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 |
CountStatAndMetric
Acts as a Count Metric, but also keeps track of approximate counts for the last 10 mins, 3 hours, 1 day, and all time.
|
class |
LatencyStatAndMetric
Acts 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 |
HistogramMetric
A metric wrapping an HdrHistogram.
|
Modifier and Type | Class and Description |
---|---|
class |
CPUMetric
A metric using Sigar to get User and System CPU utilization for a worker.
|
Modifier and Type | Method and Description |
---|---|
<T extends IMetric> |
TopologyContext.registerMetric(String name,
T metric,
int timeBucketSizeInSecs)
Deprecated.
|
<T extends IMetric> |
IMetricsContext.registerMetric(String name,
T metric,
int timeBucketSizeInSecs) |
Modifier and Type | Method and Description |
---|---|
IMetric |
TopologyContext.getRegisteredMetricByName(String name)
Deprecated.
|
Constructor and Description |
---|
TopologyContext(StormTopology topology,
Map stormConf,
Map<Integer,String> taskToComponent,
Map<String,List<Integer>> componentToSortedTasks,
Map<String,Map<String,Fields>> componentToStreamToFields,
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,
clojure.lang.Atom openOrPrepareWasCalled) |
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.