Uses of Class
org.apache.storm.cluster.ExecutorBeat
-
Uses of ExecutorBeat in org.apache.storm.cluster
Modifier and TypeMethodDescriptionstatic Map<ExecutorInfo,
ExecutorBeat> ClusterUtils.convertExecutorBeats
(List<ExecutorInfo> executors, ClusterWorkerHeartbeat workerHeartbeat) Ensures that we only return heartbeats for executors assigned to this worker.need to take executor->node+port in explicitly so that we don't run into a situation where a long dead worker with a skewed clock overrides all the timestamps. -
Uses of ExecutorBeat in org.apache.storm.stats
Modifier and TypeMethodDescriptionStatsUtil.convertZkExecutorHb
(ExecutorBeat beat) convert thrift ExecutorBeat into a java HashMap.Modifier and TypeMethodDescriptionStatsUtil.convertExecutorBeats
(Map<ExecutorInfo, ExecutorBeat> beats) convert thrift executor heartbeats into a java HashMap.