Package org.apache.storm.task
Class WorkerUserContext
java.lang.Object
org.apache.storm.task.GeneralTopologyContext
org.apache.storm.task.WorkerTopologyContext
org.apache.storm.task.WorkerUserContext
- All Implemented Interfaces:
- org.apache.storm.shade.net.minidev.json.JSONAware
- 
Field SummaryFields inherited from class org.apache.storm.task.WorkerTopologyContextSHARED_EXECUTORFields inherited from class org.apache.storm.task.GeneralTopologyContextdoSanityCheck, topoConf
- 
Constructor SummaryConstructorsConstructorDescriptionWorkerUserContext(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) 
- 
Method SummaryModifier and TypeMethodDescriptionvoidsetResource(String name, Object data) Sets the worker-level data for the given name.Methods inherited from class org.apache.storm.task.WorkerTopologyContextgetAssignmentId, getCodeDir, getNodeToHost, getPIDDir, getResource, getSharedExecutor, getTaskToNodePort, getThisWorkerPort, getThisWorkerTasksMethods inherited from class org.apache.storm.task.GeneralTopologyContextdoSanityCheck, getComponentCommon, getComponentId, getComponentIds, getComponentOutputFields, getComponentOutputFields, getComponentStreams, getComponentTasks, getConf, getRawTopology, getSources, getStormId, getTargets, getTaskToComponent, maxTopologyMessageTimeout, toJSONString
- 
Constructor Details- 
WorkerUserContextpublic 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) 
 
- 
- 
Method Details- 
setResourceSets the worker-level data for the given name. This data can then be read by all components running on the same worker, i.e. tasks (spouts, bolts), task hooks and worker hooks.- Parameters:
- name- name of the worker-level data to be set
- data- worker-level data
 
 
-