org.openimaj.storm

Class StormPlayground.JoinBolt

java.lang.Object

backtype.storm.topology.base.BaseComponent

backtype.storm.topology.base.BaseRichBolt

org.openimaj.storm.StormPlayground.JoinBolt

All Implemented Interfaces:

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

Enclosing class:

StormPlayground

public static class StormPlayground.JoinBolt
extends backtype.storm.topology.base.BaseRichBolt

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
JoinBolt()

Method Summary

Modifier and Type	Method and Description
static void	connectNewBolt(backtype.storm.topology.TopologyBuilder builder)
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

JoinBolt

public JoinBolt()

Method Detail

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)

declareOutputFields

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

connectNewBolt

public static void connectNewBolt(backtype.storm.topology.TopologyBuilder builder)