Uses of Class
org.apache.storm.generated.NodeInfo
Package
Description
-
Uses of NodeInfo in org.apache.storm.cluster
Modifier and TypeMethodDescriptionIStormClusterState.getWorkerProfileRequests
(String stormId, NodeInfo nodeInfo) StormClusterStateImpl.getWorkerProfileRequests
(String stormId, NodeInfo nodeInfo) Modifier and TypeMethodDescriptionneed 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 NodeInfo in org.apache.storm.daemon
Modifier and TypeMethodDescriptionStormCommon.taskToNodeport
(Map<List<Long>, NodeInfo> executorToNodePort) -
Uses of NodeInfo in org.apache.storm.daemon.worker
-
Uses of NodeInfo in org.apache.storm.generated
Modifier and TypeMethodDescriptionAssignment.get_executor_node_port()
Assignment.get_worker_resources()
Modifier and TypeMethodDescriptionint
boolean
void
Assignment.put_to_executor_node_port
(List<Long> key, NodeInfo val) void
Assignment.put_to_worker_resources
(NodeInfo key, WorkerResources val) void
ProfileRequest.set_nodeInfo
(NodeInfo nodeInfo) Modifier and TypeMethodDescriptionvoid
Assignment.set_executor_node_port
(Map<List<Long>, NodeInfo> executor_node_port) void
Assignment.set_worker_resources
(Map<NodeInfo, WorkerResources> worker_resources) ModifierConstructorDescriptionPerforms a deep copy on other.ProfileRequest
(NodeInfo nodeInfo, ProfileAction action) -
Uses of NodeInfo in org.apache.storm.task
Modifier and TypeMethodDescriptionWorkerTopologyContext.getTaskToNodePort()
Get a map from task Id to NodePort.ModifierConstructorDescriptionWorkerTopologyContext
(StormTopology topology, Map<String, Object> topoConf, Map<Integer, String> taskToComponent, Map<String, List<Integer>> componentToSortedTasks, Map<String, Map<String, Fields>> componentToStreamToFields, String stormId, String codeDir, String pidDir, Integer workerPort, List<Integer> workerTasks, Map<String, Object> defaultResources, Map<String, Object> userResources, AtomicReference<Map<Integer, NodeInfo>> taskToNodePort, String assignmentId, AtomicReference<Map<String, String>> nodeToHost) WorkerUserContext
(StormTopology topology, Map<String, Object> topoConf, Map<Integer, String> taskToComponent, Map<String, List<Integer>> componentToSortedTasks, Map<String, Map<String, Fields>> componentToStreamToFields, String stormId, String codeDir, String pidDir, Integer workerPort, List<Integer> workerTasks, Map<String, Object> defaultResources, Map<String, Object> userResources, AtomicReference<Map<Integer, NodeInfo>> taskToNodePort, String assignmentId, AtomicReference<Map<String, String>> nodeToHost) -
Uses of NodeInfo in org.apache.storm.utils