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 TypeMethodDescriptionintExecutorStats.compareTo(ExecutorStats other) booleanExecutorStats.equals(ExecutorStats that) voidClusterWorkerHeartbeat.put_to_executor_stats(ExecutorInfo key, ExecutorStats val) voidExecutorSummary.set_stats(ExecutorStats stats) Method parameters in org.apache.storm.generated with type arguments of type ExecutorStatsModifier and TypeMethodDescriptionvoidClusterWorkerHeartbeat.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 ExecutorStatsCommonStats.renderStats()SpoutExecutorStats.renderStats()static ExecutorStatsStatsUtil.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.