org.openimaj.storm.tools.twitter.bolts

Class BaseTwitterRichBolt

java.lang.Object

backtype.storm.topology.base.BaseComponent

backtype.storm.topology.base.BaseRichBolt

org.openimaj.storm.tools.twitter.bolts.BaseTwitterRichBolt

All Implemented Interfaces:

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

Direct Known Subclasses:

TweetPreprocessingBolt

public abstract class BaseTwitterRichBolt
extends backtype.storm.topology.base.BaseRichBolt

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
BaseTwitterRichBolt()

Method Summary

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

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

BaseTwitterRichBolt

public BaseTwitterRichBolt()

Method Detail

prepare

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

declareOutputFields

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

execute

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

processTweet

public abstract void processTweet(String string)
                           throws Exception

Throws:

Exception

prepare

public abstract void prepare()