org.apache.storm.hdfs.bolt

Class SequenceFileTopology.MyBolt

java.lang.Object

org.apache.storm.topology.base.BaseComponent

org.apache.storm.topology.base.BaseRichBolt

org.apache.storm.hdfs.bolt.SequenceFileTopology.MyBolt

All Implemented Interfaces:

Serializable, org.apache.storm.task.IBolt, org.apache.storm.topology.IComponent, org.apache.storm.topology.IRichBolt

Enclosing class:

SequenceFileTopology

public static class SequenceFileTopology.MyBolt
extends org.apache.storm.topology.base.BaseRichBolt

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
MyBolt()

Method Summary

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

Methods inherited from class org.apache.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 org.apache.storm.topology.IComponent

getComponentConfiguration

Constructor Detail

MyBolt

public MyBolt()

Method Detail

prepare

public void prepare(Map<String,Object> config,
                    org.apache.storm.task.TopologyContext context,
                    org.apache.storm.task.OutputCollector collector)

execute

public void execute(org.apache.storm.tuple.Tuple tuple)

declareOutputFields

public void declareOutputFields(org.apache.storm.topology.OutputFieldsDeclarer declarer)

cleanup

public void cleanup()

Specified by:

cleanup in interface org.apache.storm.task.IBolt

Overrides:

cleanup in class org.apache.storm.topology.base.BaseRichBolt