Uses of Class
org.apache.storm.generated.ExecutorSummary
-
Packages that use ExecutorSummary Package Description org.apache.storm.daemon.ui org.apache.storm.generated org.apache.storm.stats -
-
Uses of ExecutorSummary in org.apache.storm.daemon.ui
Methods in org.apache.storm.daemon.ui that return types with arguments of type ExecutorSummary Modifier and Type Method 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.Methods in org.apache.storm.daemon.ui with parameters of type ExecutorSummary Modifier and Type Method Description static Map<String,Object>
UIHelpers. getStatMapFromExecutorSummary(ExecutorSummary executorSummary)
getStatMapFromExecutorSummary.Method parameters in org.apache.storm.daemon.ui with type arguments of type ExecutorSummary Modifier and Type Method 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. -
Uses of ExecutorSummary in org.apache.storm.generated
Methods in org.apache.storm.generated that return ExecutorSummary Modifier and Type Method Description ExecutorSummary
ExecutorSummary. deepCopy()
ExecutorSummary
ExecutorAggregateStats. get_exec_summary()
Methods in org.apache.storm.generated that return types with arguments of type ExecutorSummary Modifier and Type Method Description List<ExecutorSummary>
TopologyInfo. get_executors()
Iterator<ExecutorSummary>
TopologyInfo. get_executors_iterator()
Methods in org.apache.storm.generated with parameters of type ExecutorSummary Modifier and Type Method 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)
Method parameters in org.apache.storm.generated with type arguments of type ExecutorSummary Modifier and Type Method Description void
TopologyInfo. set_executors(List<ExecutorSummary> executors)
Constructors in org.apache.storm.generated with parameters of type ExecutorSummary Constructor Description ExecutorSummary(ExecutorSummary other)
Performs a deep copy on other.Constructor parameters in org.apache.storm.generated with type arguments of type ExecutorSummary Constructor Description TopologyInfo(String id, String name, int uptime_secs, List<ExecutorSummary> executors, String status, Map<String,List<ErrorInfo>> errors)
-
Uses of ExecutorSummary in org.apache.storm.stats
Methods in org.apache.storm.stats that return types with arguments of type ExecutorSummary Modifier and Type Method Description static List<ExecutorSummary>
StatsUtil. getFilledStats(List<ExecutorSummary> summs)
filter ExecutorSummary whose stats is null.Methods in org.apache.storm.stats with parameters of type ExecutorSummary Modifier and Type Method Description static double
StatsUtil. computeExecutorCapacity(ExecutorSummary summary)
Compute the capacity of a executor.Method parameters in org.apache.storm.stats with type arguments of type ExecutorSummary Modifier and Type Method 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}.
-