org.openimaj.storm.bolt

Class PrintingBolt

java.lang.Object

org.openimaj.storm.bolt.PrintingBolt

All Implemented Interfaces:

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

public class PrintingBolt
extends Object
implements backtype.storm.topology.IRichBolt

A simple bolt that prints what it sees

Author:

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

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
PrintingBolt()

Method Summary

Methods

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

Methods inherited from class java.lang.Object

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

Constructor Detail

PrintingBolt

public PrintingBolt()

Method Detail

declareOutputFields

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

Specified by:

declareOutputFields in interface backtype.storm.topology.IComponent

getComponentConfiguration

public Map<String,Object> getComponentConfiguration()

Specified by:

getComponentConfiguration in interface backtype.storm.topology.IComponent

prepare

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

Specified by:

prepare in interface backtype.storm.task.IBolt

execute

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

Specified by:

execute in interface backtype.storm.task.IBolt

cleanup

public void cleanup()

Specified by:

cleanup in interface backtype.storm.task.IBolt