Uses of Class
org.apache.storm.generated.ExecutorInfo

Packages that use ExecutorInfo

Package	Description
org.apache.storm.cluster
org.apache.storm.generated

Uses of ExecutorInfo in org.apache.storm.cluster

Methods in org.apache.storm.cluster that return types with arguments of type ExecutorInfo

Modifier and Type	Method and Description
static Map<ExecutorInfo,ExecutorBeat>	ClusterUtils.convertExecutorBeats(List<ExecutorInfo> executors, ClusterWorkerHeartbeat workerHeartbeat) Ensures that we only return heartbeats for executors assigned to this worker
Map<ExecutorInfo,ExecutorBeat>	StormClusterStateImpl.executorBeats(String stormId, Map<List<Long>,NodeInfo> executorNodePort) 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.
Map<ExecutorInfo,ExecutorBeat>	IStormClusterState.executorBeats(String stormId, Map<List<Long>,NodeInfo> executorNodePort)

Method parameters in org.apache.storm.cluster with type arguments of type ExecutorInfo

Modifier and Type	Method and Description
static 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.generated

Methods in org.apache.storm.generated that return ExecutorInfo

Modifier and Type	Method and Description
ExecutorInfo	ExecutorInfo.deepCopy()
ExecutorInfo	ExecutorSummary.get_executor_info()

Methods in org.apache.storm.generated that return types with arguments of type ExecutorInfo

Modifier and Type	Method and Description
Map<ExecutorInfo,ExecutorStats>	ClusterWorkerHeartbeat.get_executor_stats()
Iterator<ExecutorInfo>	LocalAssignment.get_executors_iterator()
Iterator<ExecutorInfo>	LSWorkerHeartbeat.get_executors_iterator()
List<ExecutorInfo>	LocalAssignment.get_executors()
List<ExecutorInfo>	LSWorkerHeartbeat.get_executors()

Methods in org.apache.storm.generated with parameters of type ExecutorInfo

Modifier and Type	Method and Description
void	LocalAssignment.add_to_executors(ExecutorInfo elem)
void	LSWorkerHeartbeat.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)

Method parameters in org.apache.storm.generated with type arguments of type ExecutorInfo

Modifier and Type	Method and Description
void	ClusterWorkerHeartbeat.set_executor_stats(Map<ExecutorInfo,ExecutorStats> executor_stats)
void	LocalAssignment.set_executors(List<ExecutorInfo> executors)
void	LSWorkerHeartbeat.set_executors(List<ExecutorInfo> executors)

Constructors in org.apache.storm.generated with parameters of type ExecutorInfo

Constructor and Description
ExecutorInfo(ExecutorInfo other) Performs a deep copy on other.
ExecutorSummary(ExecutorInfo executor_info, String component_id, String host, int port, int uptime_secs)

Constructor parameters in org.apache.storm.generated with type arguments of type ExecutorInfo

Constructor and Description
ClusterWorkerHeartbeat(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)