org.apache.flink.storm.split.operators

Class VerifyAndEnrichBolt

java.lang.Object

org.apache.storm.topology.base.BaseComponent

org.apache.storm.topology.base.BaseRichBolt

org.apache.flink.storm.split.operators.VerifyAndEnrichBolt

All Implemented Interfaces:

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

public class VerifyAndEnrichBolt
extends org.apache.storm.topology.base.BaseRichBolt

Verifies that incoming numbers are either even or odd, controlled by the constructor argument. Emitted tuples are enriched with a new string field containing either "even" or "odd", based on the number's parity.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static boolean	errorOccured

Constructor Summary

Constructors

Constructor and Description
VerifyAndEnrichBolt(boolean evenOrOdd)

Method Summary

Modifier and Type	Method and Description
void	declareOutputFields(org.apache.storm.topology.OutputFieldsDeclarer declarer)
void	execute(org.apache.storm.tuple.Tuple input)
void	prepare(Map stormConf, org.apache.storm.task.TopologyContext context, org.apache.storm.task.OutputCollector collector)

Methods inherited from class org.apache.storm.topology.base.BaseRichBolt

cleanup

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

Field Detail

errorOccured

public static boolean errorOccured

Constructor Detail

VerifyAndEnrichBolt

public VerifyAndEnrichBolt(boolean evenOrOdd)

Method Detail

prepare

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

execute

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

declareOutputFields

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