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