Uses of Class
org.apache.storm.generated.ExecutorStats
Package
Description
-
Uses of ExecutorStats in org.apache.storm.cluster
-
Uses of ExecutorStats in org.apache.storm.executor
-
Uses of ExecutorStats in org.apache.storm.generated
Modifier 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) Modifier and TypeMethodDescriptionvoid
ClusterWorkerHeartbeat.set_executor_stats
(Map<ExecutorInfo, ExecutorStats> executor_stats) ModifierConstructorDescriptionClusterWorkerHeartbeat
(String storm_id, Map<ExecutorInfo, ExecutorStats> executor_stats, int time_secs, int uptime_secs) -
Uses of ExecutorStats in org.apache.storm.stats
Modifier and TypeMethodDescriptionBoltExecutorStats.renderStats()
abstract ExecutorStats
CommonStats.renderStats()
SpoutExecutorStats.renderStats()
static ExecutorStats
StatsUtil.thriftifyExecutorStats
(Map stats) Convert Executor stats to thrift data structure.Modifier 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.Modifier and TypeMethodDescriptionStatsUtil.convertExecutorStats
(ExecutorStats stats) convert thrift ExecutorStats structure into a java HashMap.Modifier 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.