backtype.storm.spout

Class TestTopology.FailEveryOther

java.lang.Object

backtype.storm.topology.base.BaseComponent

backtype.storm.topology.base.BaseRichBolt

backtype.storm.spout.TestTopology.FailEveryOther

All Implemented Interfaces:

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

Enclosing class:

TestTopology

public static class TestTopology.FailEveryOther
extends backtype.storm.topology.base.BaseRichBolt

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
FailEveryOther()

Method Summary

Modifier and Type	Method and Description
void	declareOutputFields(backtype.storm.topology.OutputFieldsDeclarer declarer)
void	execute(backtype.storm.tuple.Tuple tuple)
void	prepare(Map map, backtype.storm.task.TopologyContext tc, 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

FailEveryOther

public FailEveryOther()

Method Detail

prepare

public void prepare(Map map,
                    backtype.storm.task.TopologyContext tc,
                    backtype.storm.task.OutputCollector collector)

execute

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

declareOutputFields

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