public interface GeneralTopologyContext
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getComponentId(int taskId)
Gets the component id for the specified task id.
|
java.util.Set<java.lang.String> |
getComponentIds()
Gets a list of all component ids in this topology
|
Fields |
getComponentOutputFields(java.lang.String componentId,
java.lang.String streamId)
Gets the declared output fields for the specified component/stream.
|
java.util.Set<java.lang.String> |
getComponentStreams(java.lang.String componentId)
Gets the set of streams declared for the specified component.
|
java.util.List<java.lang.Integer> |
getComponentTasks(java.lang.String componentId)
Gets the task ids allocated for the given component id.
|
java.util.Map<TopologyAPI.StreamId,TopologyAPI.Grouping> |
getSources(java.lang.String componentId)
Gets the declared inputs to the specified component.
|
java.util.Map<java.lang.String,java.util.Map<java.lang.String,TopologyAPI.Grouping>> |
getTargets(java.lang.String componentId)
Gets information about who is consuming the outputs of the specified component,
and how.
|
java.util.Map<java.lang.Integer,java.lang.String> |
getTaskToComponent()
Gets a map from task id to component id.
|
java.lang.String |
getTopologyId()
Gets the unique id assigned to this topology.
|
int |
maxTopologyMessageTimeout() |
java.lang.String getTopologyId()
java.lang.String getComponentId(int taskId)
taskId
- the task idjava.util.Set<java.lang.String> getComponentStreams(java.lang.String componentId)
java.util.List<java.lang.Integer> getComponentTasks(java.lang.String componentId)
Fields getComponentOutputFields(java.lang.String componentId, java.lang.String streamId)
java.util.Map<TopologyAPI.StreamId,TopologyAPI.Grouping> getSources(java.lang.String componentId)
java.util.Map<java.lang.String,java.util.Map<java.lang.String,TopologyAPI.Grouping>> getTargets(java.lang.String componentId)
java.util.Map<java.lang.Integer,java.lang.String> getTaskToComponent()
java.util.Set<java.lang.String> getComponentIds()
int maxTopologyMessageTimeout()