org.thales.punch.libraries.storm.core.topology.light

Class LightComponent

java.lang.Object

org.thales.punch.libraries.storm.core.topology.light.LightComponent

Direct Known Subclasses:

LightBoltDispatcher, LightBoltRunner, LightSpout

public class LightComponent
extends Object

A (bolt or spout) component.

Watch out this is also the parent class for LightBoltDispatcher.

Author:

dimi

Field Summary

Fields

Modifier and Type	Field and Description
protected String	componentId
protected Map<String,org.apache.storm.tuple.Fields>	streamDeclaration
protected Map<String,List<LightBoltDispatcher>>	subscribersPerStreamId
protected org.apache.storm.task.TopologyContext	topologyContext

Constructor Summary

Constructors

Constructor and Description
LightComponent(LightTopology topology, String componentId, org.apache.storm.task.TopologyContext topologyContext)

Method Summary

Modifier and Type	Method and Description
void	addSubscriber(LightBoltDispatcher lightBoltDispatcher, String streamId) A bolt dispatcher comes in to subscribe to tuples from a given stream
void	declareStream(String streamId, org.apache.storm.tuple.Fields fields) Make this component publish some fields over a stream
String	getComponentId()
org.apache.storm.task.TopologyContext	getTopologyContext() The associated topology context is actually per component, as it provides per component informations such as the component identifier.
boolean	publishStream(String streamId)

Methods inherited from class java.lang.Object

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

Field Detail

topologyContext

protected org.apache.storm.task.TopologyContext topologyContext

streamDeclaration

protected Map<String,org.apache.storm.tuple.Fields> streamDeclaration

subscribersPerStreamId

protected Map<String,List<LightBoltDispatcher>> subscribersPerStreamId

componentId

protected String componentId

Constructor Detail

LightComponent

public LightComponent(LightTopology topology,
                      String componentId,
                      org.apache.storm.task.TopologyContext topologyContext)

Method Detail

getTopologyContext

public org.apache.storm.task.TopologyContext getTopologyContext()

The associated topology context is actually per component, as it provides per component informations such as the component identifier.

Returns:

The associated topology context

getComponentId

public String getComponentId()

Returns:

this component identifier

addSubscriber

public void addSubscriber(LightBoltDispatcher lightBoltDispatcher,
                          String streamId)

A bolt dispatcher comes in to subscribe to tuples from a given stream

Parameters:

lightBoltDispatcher - the subscriber bolt

streamId - the corresponding stream identifier

publishStream

public boolean publishStream(String streamId)

Parameters:

streamId - a stream identifier

Returns:

true if this component publish over that stream

declareStream

public void declareStream(String streamId,
                          org.apache.storm.tuple.Fields fields)

Make this component publish some fields over a stream

Parameters:

streamId - the stream identifier

fields - the corresponding fields