Uses of Class
org.apache.storm.generated.ExecutorInfo
Package
Description
-
Uses of ExecutorInfo 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.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. -
Uses of ExecutorInfo in org.apache.storm.daemon.ui
Modifier and TypeMethodDescriptionstatic String
UIHelpers.prettyExecutorInfo
(ExecutorInfo e) Prettified executor info. -
Uses of ExecutorInfo in org.apache.storm.generated
Modifier and TypeMethodDescriptionClusterWorkerHeartbeat.get_executor_stats()
LocalAssignment.get_executors()
LSWorkerHeartbeat.get_executors()
SupervisorWorkerHeartbeat.get_executors()
LocalAssignment.get_executors_iterator()
LSWorkerHeartbeat.get_executors_iterator()
SupervisorWorkerHeartbeat.get_executors_iterator()
Modifier and TypeMethodDescriptionvoid
LocalAssignment.add_to_executors
(ExecutorInfo elem) void
LSWorkerHeartbeat.add_to_executors
(ExecutorInfo elem) void
SupervisorWorkerHeartbeat.add_to_executors
(ExecutorInfo elem) int
ExecutorInfo.compareTo
(ExecutorInfo other) boolean
ExecutorInfo.equals
(ExecutorInfo that) void
ClusterWorkerHeartbeat.put_to_executor_stats
(ExecutorInfo key, ExecutorStats val) void
ExecutorSummary.set_executor_info
(ExecutorInfo executor_info) Modifier and TypeMethodDescriptionvoid
ClusterWorkerHeartbeat.set_executor_stats
(Map<ExecutorInfo, ExecutorStats> executor_stats) void
LocalAssignment.set_executors
(List<ExecutorInfo> executors) void
LSWorkerHeartbeat.set_executors
(List<ExecutorInfo> executors) void
SupervisorWorkerHeartbeat.set_executors
(List<ExecutorInfo> executors) ModifierConstructorDescriptionExecutorInfo
(ExecutorInfo other) Performs a deep copy on other.ExecutorSummary
(ExecutorInfo executor_info, String component_id, String host, int port, int uptime_secs) ModifierConstructorDescriptionClusterWorkerHeartbeat
(String storm_id, Map<ExecutorInfo, ExecutorStats> executor_stats, int time_secs, int uptime_secs) LocalAssignment
(String topology_id, List<ExecutorInfo> executors) LSWorkerHeartbeat
(int time_secs, String topology_id, List<ExecutorInfo> executors, int port) SupervisorWorkerHeartbeat
(String storm_id, List<ExecutorInfo> executors, int time_secs) -
Uses of ExecutorInfo in org.apache.storm.stats
Modifier and TypeMethodDescriptionStatsUtil.convertExecutorBeats
(Map<ExecutorInfo, ExecutorBeat> beats) convert thrift executor heartbeats into a java HashMap.static Map<List<Integer>,
ExecutorStats> StatsUtil.convertExecutorsStats
(Map<ExecutorInfo, ExecutorStats> stats) convert executors stats into a HashMap, note that ExecutorStats are remained unchanged.