org.apache.flink.storm.exclamation.operators

Class ExclamationBolt

java.lang.Object

org.apache.flink.storm.exclamation.operators.ExclamationBolt

All Implemented Interfaces:

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

public class ExclamationBolt
extends Object
implements org.apache.storm.topology.IRichBolt

A Bolt implementation that appends exclamation marks to incoming tuples. The number of added exclamation marks can be controlled by setting exclamation.count.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static String	EXCLAMATION_COUNT

Constructor Summary

Constructors

Constructor and Description
ExclamationBolt()

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)
Map<String,Object>	getComponentConfiguration()
void	prepare(Map conf, org.apache.storm.task.TopologyContext context, org.apache.storm.task.OutputCollector collector)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

EXCLAMATION_COUNT

public static final String EXCLAMATION_COUNT

See Also:

Constant Field Values

Constructor Detail

ExclamationBolt

public ExclamationBolt()

Method Detail

prepare

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

Specified by:

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

cleanup

public void cleanup()

Specified by:

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

execute

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

Specified by:

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

declareOutputFields

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

Specified by:

declareOutputFields in interface org.apache.storm.topology.IComponent

getComponentConfiguration

public Map<String,Object> getComponentConfiguration()

Specified by:

getComponentConfiguration in interface org.apache.storm.topology.IComponent