Package org.apache.storm.task
Class GeneralTopologyContext
java.lang.Object
org.apache.storm.task.GeneralTopologyContext
- All Implemented Interfaces:
org.apache.storm.shade.net.minidev.json.JSONAware
- Direct Known Subclasses:
WorkerTopologyContext
public class GeneralTopologyContext
extends Object
implements org.apache.storm.shade.net.minidev.json.JSONAware
-
Field Summary
Modifier and TypeFieldDescriptionprotected boolean
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionboolean
getComponentCommon
(String componentId) getComponentId
(int taskId) Gets the component id for the specified task id.Gets a list of all component ids in this topology.getComponentOutputFields
(String componentId, String streamId) Gets the declared output fields for the specified component/stream.Gets the declared output fields for the specified global stream id.getComponentStreams
(String componentId) Gets the set of streams declared for the specified component.getComponentTasks
(String componentId) Gets the task ids allocated for the given component id.getConf()
Gets the Thrift object representing the topology.getSources
(String componentId) Gets the declared inputs to the specified component.Gets the unique id assigned to this topology.getTargets
(String componentId) Gets information about who is consuming the outputs of the specified component, and how.Gets a map from task id to component id.int
-
Field Details
-
topoConf
-
doSanityCheck
protected boolean doSanityCheck
-
-
Constructor Details
-
GeneralTopologyContext
-
-
Method Details
-
getStormId
Gets the unique id assigned to this topology. The id is the storm name with a unique nonce appended to it.- Returns:
- the storm id
-
getRawTopology
Gets the Thrift object representing the topology.- Returns:
- the Thrift definition representing the topology
-
getComponentId
Gets the component id for the specified task id. The component id maps to a component id specified for a Spout or Bolt in the topology definition.- Parameters:
taskId
- the task id- Returns:
- the component id for the input task id
-
getComponentStreams
Gets the set of streams declared for the specified component. -
getComponentTasks
Gets the task ids allocated for the given component id. The task ids are always returned in ascending order. -
getComponentOutputFields
Gets the declared output fields for the specified component/stream. -
getComponentOutputFields
Gets the declared output fields for the specified global stream id. -
getSources
Gets the declared inputs to the specified component.- Returns:
- A map from subscribed component/stream to the grouping subscribed with.
-
getTargets
Gets information about who is consuming the outputs of the specified component, and how.- Returns:
- Map from stream id to component id to the Grouping used.
-
toJSONString
- Specified by:
toJSONString
in interfaceorg.apache.storm.shade.net.minidev.json.JSONAware
-
getTaskToComponent
Gets a map from task id to component id. -
getComponentIds
Gets a list of all component ids in this topology. -
getComponentCommon
-
maxTopologyMessageTimeout
public int maxTopologyMessageTimeout() -
getConf
-
doSanityCheck
public boolean doSanityCheck()
-