Uses of Class
org.apache.storm.generated.ExecutorSummary
-
Uses of ExecutorSummary in org.apache.storm.daemon.ui
Modifier and TypeMethodDescriptionstatic 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 TypeMethodDescriptionUIHelpers.getStatMapFromExecutorSummary
(ExecutorSummary executorSummary) getStatMapFromExecutorSummary.Modifier and TypeMethodDescriptionstatic 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
Modifier and TypeMethodDescriptionExecutorSummary.deepCopy()
ExecutorAggregateStats.get_exec_summary()
Modifier and TypeMethodDescriptionTopologyInfo.get_executors()
TopologyInfo.get_executors_iterator()
Modifier and TypeMethodDescriptionvoid
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 TypeMethodDescriptionvoid
TopologyInfo.set_executors
(List<ExecutorSummary> executors) ModifierConstructorDescriptionExecutorSummary
(ExecutorSummary other) Performs a deep copy on other.ModifierConstructorDescriptionTopologyInfo
(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
Modifier and TypeMethodDescriptionstatic List<ExecutorSummary>
StatsUtil.getFilledStats
(List<ExecutorSummary> summs) filter ExecutorSummary whose stats is null.Modifier and TypeMethodDescriptionstatic double
StatsUtil.computeExecutorCapacity
(ExecutorSummary summary) Compute the capacity of a executor. approximation of the % of time spent doing real work.Modifier and TypeMethodDescriptionStatsUtil.aggregateBoltStats
(List<ExecutorSummary> statsSeq, boolean includeSys) aggregate bolt stats.StatsUtil.aggregateCommonStats
(List<ExecutorSummary> statsSeq) aggregate common stats from a spout/bolt, called in aggregateSpoutStats/aggregateBoltStats.StatsUtil.aggregateSpoutStats
(List<ExecutorSummary> statsSeq, boolean includeSys) aggregate spout stats.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.StatsUtil.spoutStreamsStats
(List<ExecutorSummary> summs, boolean includeSys) aggregates spout stream stats, returns a Map of {metric -> win -> aggregated value}.