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
Deprecated.
|
class |
CGroupCpuGuarantee
Deprecated.
|
class |
CGroupCpuGuaranteeByCfsQuota
Deprecated.
|
class |
CGroupMemoryLimit
Deprecated.
|
class |
CGroupMemoryUsage
Deprecated.
|
class |
CGroupMetricsBase<T>
Deprecated.
|
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> |
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 © 2023 The Apache Software Foundation. All rights reserved.