com.twitter.heron.common.utils.topology

Class GeneralTopologyContextImpl

java.lang.Object

com.twitter.heron.common.utils.topology.GeneralTopologyContextImpl

All Implemented Interfaces:

GeneralTopologyContext

Direct Known Subclasses:

TopologyContextImpl

public class GeneralTopologyContextImpl
extends java.lang.Object
implements GeneralTopologyContext

From Heron. To get the topology info.

Constructor Summary

Constructors

Constructor and Description
GeneralTopologyContextImpl(java.util.Map<java.lang.String,java.lang.Object> clusterConfig, TopologyAPI.Topology topology, java.util.Map<java.lang.Integer,java.lang.String> taskToComponentMap)

Method Summary

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.
static java.util.Map<java.lang.String,java.util.Map<java.lang.String,Fields>>	getOutputToComponentsFields(java.util.List<TopologyAPI.OutputStream> outputs)
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.util.Map<java.lang.String,java.lang.Object>	getTopologyConfig()
java.lang.String	getTopologyId() Gets the unique id assigned to this topology.
int	maxTopologyMessageTimeout()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

GeneralTopologyContextImpl

public GeneralTopologyContextImpl(java.util.Map<java.lang.String,java.lang.Object> clusterConfig,
                                  TopologyAPI.Topology topology,
                                  java.util.Map<java.lang.Integer,java.lang.String> taskToComponentMap)

Method Detail

getOutputToComponentsFields

public static java.util.Map<java.lang.String,java.util.Map<java.lang.String,Fields>> getOutputToComponentsFields(java.util.List<TopologyAPI.OutputStream> outputs)

getTopologyConfig

public java.util.Map<java.lang.String,java.lang.Object> getTopologyConfig()

getTopologyId

public java.lang.String getTopologyId()

Gets the unique id assigned to this topology. The id is the topology name with a unique nonce appended to it.

Specified by:

getTopologyId in interface GeneralTopologyContext

Returns:

the topology id

getComponentId

public java.lang.String getComponentId(int taskId)

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.

Specified by:

getComponentId in interface GeneralTopologyContext

Parameters:

taskId - the task id

Returns:

the component id for the input task id

getComponentStreams

public java.util.Set<java.lang.String> getComponentStreams(java.lang.String componentId)

Gets the set of streams declared for the specified component.

Specified by:

getComponentStreams in interface GeneralTopologyContext

getComponentTasks

public java.util.List<java.lang.Integer> getComponentTasks(java.lang.String componentId)

Gets the task ids allocated for the given component id. The task ids are always returned in ascending order.

Specified by:

getComponentTasks in interface GeneralTopologyContext

getComponentOutputFields

public Fields getComponentOutputFields(java.lang.String componentId,
                                       java.lang.String streamId)

Gets the declared output fields for the specified component/stream.

Specified by:

getComponentOutputFields in interface GeneralTopologyContext

getSources

public java.util.Map<TopologyAPI.StreamId,TopologyAPI.Grouping> getSources(java.lang.String componentId)

Gets the declared inputs to the specified component.

Specified by:

getSources in interface GeneralTopologyContext

Returns:

A map from subscribed component/stream to the grouping subscribed with.

getTargets

public 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.

Specified by:

getTargets in interface GeneralTopologyContext

Returns:

Map from stream id to component id to the Grouping used.

getTaskToComponent

public java.util.Map<java.lang.Integer,java.lang.String> getTaskToComponent()

Gets a map from task id to component id.

Specified by:

getTaskToComponent in interface GeneralTopologyContext

getComponentIds

public java.util.Set<java.lang.String> getComponentIds()

Gets a list of all component ids in this topology

Specified by:

getComponentIds in interface GeneralTopologyContext

maxTopologyMessageTimeout

public int maxTopologyMessageTimeout()

Specified by:

maxTopologyMessageTimeout in interface GeneralTopologyContext