org.apache.storm.testing

Class KeyedCountingCommitterBolt

java.lang.Object

org.apache.storm.topology.base.BaseComponent

org.apache.storm.topology.base.BaseBatchBolt

org.apache.storm.testing.KeyedCountingBatchBolt

org.apache.storm.testing.KeyedCountingCommitterBolt

All Implemented Interfaces:

Serializable, IBatchBolt, IComponent, ICommitter

public class KeyedCountingCommitterBolt
extends KeyedCountingBatchBolt
implements ICommitter

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
KeyedCountingCommitterBolt()

Method Summary

Methods inherited from class org.apache.storm.testing.KeyedCountingBatchBolt

declareOutputFields, execute, finishBatch, prepare

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

KeyedCountingCommitterBolt

public KeyedCountingCommitterBolt()