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

Class LightBoltRunner

java.lang.Object

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

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

All Implemented Interfaces:

Runnable

public class LightBoltRunner
extends LightComponent
implements Runnable

A LightBoltRunner is in charge of running one instance of a bolt.

This class is basically a Runnable. Each runs in a dedicated thread, and continuously loops waiting for input tuples.

Author:

dimi

Field Summary

Fields inherited from class org.thales.punch.libraries.storm.core.topology.light.LightComponent

componentId, streamDeclaration, subscribersPerStreamId, topologyContext

Constructor Summary

Constructors

Constructor and Description
LightBoltRunner(LightTopology topology, org.apache.storm.task.TopologyContext topologyContext, LightBoltDispatcher boltDispatcher, org.apache.storm.topology.IRichBolt boltInstance)

Method Summary

Modifier and Type	Method and Description
void	emit(String streamId, List<Object> values, LightTuple anchor) Emit a tuple from a bolt.
org.apache.storm.task.OutputCollector	getLightOutputCollector()
void	run()
void	setTickFrequency(Integer tickFrequencySec)

Methods inherited from class org.thales.punch.libraries.storm.core.topology.light.LightComponent

addSubscriber, declareStream, getComponentId, getTopologyContext, publishStream

Methods inherited from class java.lang.Object

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

Constructor Detail

LightBoltRunner

public LightBoltRunner(LightTopology topology,
                       org.apache.storm.task.TopologyContext topologyContext,
                       LightBoltDispatcher boltDispatcher,
                       org.apache.storm.topology.IRichBolt boltInstance)

Method Detail

run

public void run()

Specified by:

run in interface Runnable

getLightOutputCollector

public org.apache.storm.task.OutputCollector getLightOutputCollector()

Returns:

the associated output collector

emit

public void emit(String streamId,
                 List<Object> values,
                 LightTuple anchor)

Emit a tuple from a bolt.

Parameters:

streamId - the stream identifier

values - the values to be emitted

anchor - the anchored tuple, if any.

setTickFrequency

public void setTickFrequency(Integer tickFrequencySec)