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 |
DeserializingConnectionCallback
A 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 |
CGroupCpu
Report CPU used in the cgroup.
|
class |
CGroupCpuGuarantee
Report the guaranteed number of ms this worker has requested.
|
class |
CGroupMemoryLimit
Reports the current memory limit of the cgroup for this worker.
|
class |
CGroupMemoryUsage
Reports 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 |
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)
Deprecated.
in favor of metrics v2 (the non-deprecated methods on this class)
|
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 © 2020 The Apache Software Foundation. All rights reserved.