Uses of Class
org.apache.storm.generated.ExecutorStats
-
Packages that use ExecutorStats Package Description org.apache.storm.cluster org.apache.storm.executor org.apache.storm.generated org.apache.storm.stats -
-
Uses of ExecutorStats in org.apache.storm.cluster
Methods in org.apache.storm.cluster that return ExecutorStats Modifier and Type Method Description ExecutorStats
ExecutorBeat. getStats()
Constructors in org.apache.storm.cluster with parameters of type ExecutorStats Constructor Description ExecutorBeat(int timeSecs, int uptime, ExecutorStats stats)
-
Uses of ExecutorStats in org.apache.storm.executor
Methods in org.apache.storm.executor that return ExecutorStats Modifier and Type Method Description ExecutorStats
ExecutorShutdown. renderStats()
ExecutorStats
IRunningExecutor. renderStats()
-
Uses of ExecutorStats in org.apache.storm.generated
Methods in org.apache.storm.generated that return ExecutorStats Modifier and Type Method Description ExecutorStats
ExecutorStats. deepCopy()
ExecutorStats
ExecutorSummary. get_stats()
Methods in org.apache.storm.generated that return types with arguments of type ExecutorStats Modifier and Type Method Description Map<ExecutorInfo,ExecutorStats>
ClusterWorkerHeartbeat. get_executor_stats()
Methods in org.apache.storm.generated with parameters of type ExecutorStats Modifier and Type Method Description int
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 ExecutorStats Modifier and Type Method Description void
ClusterWorkerHeartbeat. set_executor_stats(Map<ExecutorInfo,ExecutorStats> executor_stats)
Constructors in org.apache.storm.generated with parameters of type ExecutorStats Constructor Description ExecutorStats(ExecutorStats other)
Performs a deep copy on other.Constructor parameters in org.apache.storm.generated with type arguments of type ExecutorStats Constructor Description ClusterWorkerHeartbeat(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 ExecutorStats Modifier and Type Method Description ExecutorStats
BoltExecutorStats. renderStats()
abstract ExecutorStats
CommonStats. renderStats()
ExecutorStats
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 ExecutorStats Modifier and Type Method Description static 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 ExecutorStats Modifier and Type Method Description static Map<String,Object>
StatsUtil. convertExecutorStats(ExecutorStats stats)
convert thrift ExecutorStats structure into a java HashMap.Method parameters in org.apache.storm.stats with type arguments of type ExecutorStats Modifier and Type Method Description static 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<String,Object>
ClientStatsUtil. mkZkWorkerHb(String topoId, Map<List<Integer>,ExecutorStats> executorStats, Integer uptime)
Create a new worker heartbeat for zookeeper.
-