Package | Description |
---|---|
org.apache.storm.daemon.ui | |
org.apache.storm.generated | |
org.apache.storm.stats |
Modifier and Type | Method and Description |
---|---|
static Map<String,List<ExecutorSummary>> |
UIHelpers.getBoltExecutors(List<ExecutorSummary> executorSummaries,
StormTopology stormTopology,
boolean sys)
getBoltExecutors.
|
static Map<String,List<ExecutorSummary>> |
UIHelpers.getSpoutExecutors(List<ExecutorSummary> executorSummaries,
StormTopology stormTopology)
getSpoutExecutors.
|
Modifier and Type | Method and Description |
---|---|
static Map<String,Object> |
UIHelpers.getStatMapFromExecutorSummary(ExecutorSummary executorSummary)
getStatMapFromExecutorSummary.
|
Modifier and Type | Method and Description |
---|---|
static Map<String,List<ExecutorSummary>> |
UIHelpers.getBoltExecutors(List<ExecutorSummary> executorSummaries,
StormTopology stormTopology,
boolean sys)
getBoltExecutors.
|
static Map<String,List<ExecutorSummary>> |
UIHelpers.getSpoutExecutors(List<ExecutorSummary> executorSummaries,
StormTopology stormTopology)
getSpoutExecutors.
|
Modifier and Type | Method and Description |
---|---|
ExecutorSummary |
ExecutorSummary.deepCopy() |
ExecutorSummary |
ExecutorAggregateStats.get_exec_summary() |
Modifier and Type | Method and Description |
---|---|
Iterator<ExecutorSummary> |
TopologyInfo.get_executors_iterator() |
List<ExecutorSummary> |
TopologyInfo.get_executors() |
Modifier and Type | Method and Description |
---|---|
void |
TopologyInfo.add_to_executors(ExecutorSummary elem) |
int |
ExecutorSummary.compareTo(ExecutorSummary other) |
boolean |
ExecutorSummary.equals(ExecutorSummary that) |
void |
ExecutorAggregateStats.set_exec_summary(ExecutorSummary exec_summary) |
Modifier and Type | Method and Description |
---|---|
void |
TopologyInfo.set_executors(List<ExecutorSummary> executors) |
Constructor and Description |
---|
ExecutorSummary(ExecutorSummary other)
Performs a deep copy on other.
|
Constructor and Description |
---|
TopologyInfo(String id,
String name,
int uptime_secs,
List<ExecutorSummary> executors,
String status,
Map<String,List<ErrorInfo>> errors) |
Modifier and Type | Method and Description |
---|---|
static List<ExecutorSummary> |
StatsUtil.getFilledStats(List<ExecutorSummary> summs)
filter ExecutorSummary whose stats is null.
|
Modifier and Type | Method and Description |
---|---|
static double |
StatsUtil.computeExecutorCapacity(ExecutorSummary summary)
Compute the capacity of a executor.
|
Modifier and Type | Method and Description |
---|---|
static <T> Map<String,Map> |
StatsUtil.aggregateBoltStats(List<ExecutorSummary> statsSeq,
boolean includeSys)
aggregate bolt stats.
|
static <T> Map<String,Map<String,Map<T,Long>>> |
StatsUtil.aggregateCommonStats(List<ExecutorSummary> statsSeq)
aggregate common stats from a spout/bolt, called in aggregateSpoutStats/aggregateBoltStats.
|
static Map<String,Map> |
StatsUtil.aggregateSpoutStats(List<ExecutorSummary> statsSeq,
boolean includeSys)
aggregate spout stats.
|
static Map<String,Map> |
StatsUtil.boltStreamsStats(List<ExecutorSummary> summs,
boolean includeSys)
aggregates bolt stream stats, returns a Map of {metric -> win -> aggregated value}.
|
static double |
StatsUtil.computeBoltCapacity(List<ExecutorSummary> executorSumms)
computes max bolt capacity.
|
static List<ExecutorSummary> |
StatsUtil.getFilledStats(List<ExecutorSummary> summs)
filter ExecutorSummary whose stats is null.
|
static Map<String,Map> |
StatsUtil.spoutStreamsStats(List<ExecutorSummary> summs,
boolean includeSys)
aggregates spout stream stats, returns a Map of {metric -> win -> aggregated value}.
|
Copyright © 2022 The Apache Software Foundation. All rights reserved.