org.openimaj.storm.bolt

Class CountingEmittingBolt

java.lang.Object

backtype.storm.topology.base.BaseComponent

backtype.storm.topology.base.BaseRichBolt

org.openimaj.storm.bolt.CountingEmittingBolt

All Implemented Interfaces:

backtype.storm.task.IBolt, backtype.storm.topology.IComponent, backtype.storm.topology.IRichBolt, Serializable

public class CountingEmittingBolt
extends backtype.storm.topology.base.BaseRichBolt

A simple Storm IBasicBolt whose purpose is to increment a count on the reciept of a tuple followed by an emit of the same tuple.

Author:

Sina Samangooei (ss@ecs.soton.ac.uk)

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
CountingEmittingBolt(backtype.storm.tuple.Fields fields)

Method Summary

Modifier and Type	Method and Description
void	declareOutputFields(backtype.storm.topology.OutputFieldsDeclarer declarer)
void	execute(backtype.storm.tuple.Tuple input)
void	prepare(Map stormConf, backtype.storm.task.TopologyContext context, backtype.storm.task.OutputCollector collector)

Methods inherited from class backtype.storm.topology.base.BaseRichBolt

cleanup

Methods inherited from class backtype.storm.topology.base.BaseComponent

getComponentConfiguration

Methods inherited from class java.lang.Object

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

Methods inherited from interface backtype.storm.topology.IComponent

getComponentConfiguration

Constructor Detail

CountingEmittingBolt

public CountingEmittingBolt(backtype.storm.tuple.Fields fields)

Parameters:

fields - the fields to expect and emit

Method Detail

declareOutputFields

public void declareOutputFields(backtype.storm.topology.OutputFieldsDeclarer declarer)

prepare

public void prepare(Map stormConf,
                    backtype.storm.task.TopologyContext context,
                    backtype.storm.task.OutputCollector collector)

execute

public void execute(backtype.storm.tuple.Tuple input)