Uses of Class
org.apache.storm.generated.ExecutorStats
Packages that use ExecutorStats
Package
Description
-
Uses of ExecutorStats in org.apache.storm.cluster
Methods in org.apache.storm.cluster that return ExecutorStatsConstructors in org.apache.storm.cluster with parameters of type ExecutorStats -
Uses of ExecutorStats in org.apache.storm.executor
Methods in org.apache.storm.executor that return ExecutorStats -
Uses of ExecutorStats in org.apache.storm.generated
Methods in org.apache.storm.generated that return ExecutorStatsMethods in org.apache.storm.generated that return types with arguments of type ExecutorStatsMethods in org.apache.storm.generated with parameters of type ExecutorStatsModifier and TypeMethodDescriptionint
ExecutorStats.compareTo
(ExecutorStats other) boolean
ExecutorStats.equals
(ExecutorStats that) void
ClusterWorkerHeartbeat.put_to_executor_stats
(ExecutorInfo key, ExecutorStats val) void
ExecutorSummary.set_stats
(ExecutorStats stats) Method parameters in org.apache.storm.generated with type arguments of type ExecutorStatsModifier and TypeMethodDescriptionvoid
ClusterWorkerHeartbeat.set_executor_stats
(Map<ExecutorInfo, ExecutorStats> executor_stats) Constructors in org.apache.storm.generated with parameters of type ExecutorStatsConstructor parameters in org.apache.storm.generated with type arguments of type ExecutorStatsModifierConstructorDescriptionClusterWorkerHeartbeat
(String storm_id, Map<ExecutorInfo, ExecutorStats> executor_stats, int time_secs, int uptime_secs) -
Uses of ExecutorStats in org.apache.storm.stats
Methods in org.apache.storm.stats that return ExecutorStatsModifier and TypeMethodDescriptionBoltExecutorStats.renderStats()
abstract ExecutorStats
CommonStats.renderStats()
SpoutExecutorStats.renderStats()
static ExecutorStats
StatsUtil.thriftifyExecutorStats
(Map stats) Convert Executor stats to thrift data structure.Methods in org.apache.storm.stats that return types with arguments of type ExecutorStatsModifier and TypeMethodDescriptionstatic Map<List<Integer>,
ExecutorStats> StatsUtil.convertExecutorsStats
(Map<ExecutorInfo, ExecutorStats> stats) convert executors stats into a HashMap, note that ExecutorStats are remained unchanged.static Map<List<Integer>,
ExecutorStats> ClientStatsUtil.convertExecutorZkHbs
(Map<List<Long>, ExecutorStats> executorBeats) Convert Long Executor Ids in ZkHbs to Integer ones structure to java maps.static Map<List<Integer>,
ExecutorStats> ClientStatsUtil.mkEmptyExecutorZkHbs
(Set<List<Long>> executors) Make an map of executors to empty stats, in preparation for doing a heartbeat.Methods in org.apache.storm.stats with parameters of type ExecutorStatsModifier and TypeMethodDescriptionStatsUtil.convertExecutorStats
(ExecutorStats stats) convert thrift ExecutorStats structure into a java HashMap.Method parameters in org.apache.storm.stats with type arguments of type ExecutorStatsModifier and TypeMethodDescriptionstatic Map<List<Integer>,
ExecutorStats> StatsUtil.convertExecutorsStats
(Map<ExecutorInfo, ExecutorStats> stats) convert executors stats into a HashMap, note that ExecutorStats are remained unchanged.static Map<List<Integer>,
ExecutorStats> ClientStatsUtil.convertExecutorZkHbs
(Map<List<Long>, ExecutorStats> executorBeats) Convert Long Executor Ids in ZkHbs to Integer ones structure to java maps.ClientStatsUtil.mkZkWorkerHb
(String topoId, Map<List<Integer>, ExecutorStats> executorStats, Integer uptime) Create a new worker heartbeat for zookeeper.