| 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 © 2020 The Apache Software Foundation. All rights reserved.