backtype.storm.testing

Class KeyedCountingCommitterBolt

java.lang.Object

backtype.storm.topology.base.BaseComponent

backtype.storm.topology.base.BaseBatchBolt

backtype.storm.testing.KeyedCountingBatchBolt

backtype.storm.testing.KeyedCountingCommitterBolt

All Implemented Interfaces:

IBatchBolt, IComponent, ICommitter, Serializable

public class KeyedCountingCommitterBolt
extends KeyedCountingBatchBolt
implements ICommitter

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
KeyedCountingCommitterBolt()

Method Summary

Methods inherited from class backtype.storm.testing.KeyedCountingBatchBolt

declareOutputFields, execute, finishBatch, prepare

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

KeyedCountingCommitterBolt

public KeyedCountingCommitterBolt()