Uses of Class org.apache.storm.generated.ExecutorInfo (Storm 2.7.1 API)

Packages that use ExecutorInfo
Package Description

org.apache.storm.cluster

org.apache.storm.daemon.ui

org.apache.storm.generated

org.apache.storm.stats

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	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>`	IStormClusterState.`executorBeats(String stormId, Map<List<Long>,NodeInfo> executorNodePort)`
`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.

Method parameters in org.apache.storm.cluster with type arguments of type ExecutorInfo
Modifier and Type	Method	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.daemon.ui

Methods in org.apache.storm.daemon.ui with parameters of type ExecutorInfo
Modifier and Type	Method	Description
`static String`	UIHelpers.`prettyExecutorInfo(ExecutorInfo e)`	Prettified executor info.

Uses of ExecutorInfo in org.apache.storm.generated

Methods in org.apache.storm.generated that return ExecutorInfo
Modifier and Type	Method	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	Description
`Map<ExecutorInfo,ExecutorStats>`	ClusterWorkerHeartbeat.`get_executor_stats()`
`List<ExecutorInfo>`	LocalAssignment.`get_executors()`
`List<ExecutorInfo>`	LSWorkerHeartbeat.`get_executors()`
`List<ExecutorInfo>`	SupervisorWorkerHeartbeat.`get_executors()`
`Iterator<ExecutorInfo>`	LocalAssignment.`get_executors_iterator()`
`Iterator<ExecutorInfo>`	LSWorkerHeartbeat.`get_executors_iterator()`
`Iterator<ExecutorInfo>`	SupervisorWorkerHeartbeat.`get_executors_iterator()`

Methods in org.apache.storm.generated with parameters of type ExecutorInfo
Modifier and Type	Method	Description
`void`	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)`

Method parameters in org.apache.storm.generated with type arguments of type ExecutorInfo
Modifier and Type	Method	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)`
`void`	SupervisorWorkerHeartbeat.`set_executors(List<ExecutorInfo> executors)`

Constructors in org.apache.storm.generated with parameters of type ExecutorInfo
Constructor	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	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)`
`SupervisorWorkerHeartbeat(String storm_id, List<ExecutorInfo> executors, int time_secs)`

Uses of ExecutorInfo in org.apache.storm.stats

Method parameters in org.apache.storm.stats with type arguments of type ExecutorInfo
Modifier and Type	Method	Description
`static Map<List<Integer>,Map<String,Object>>`	StatsUtil.`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.