org.apache.storm.topology.base

Class BaseTransactionalBolt

java.lang.Object

org.apache.storm.topology.base.BaseComponent

org.apache.storm.topology.base.BaseBatchBolt<TransactionAttempt>

org.apache.storm.topology.base.BaseTransactionalBolt

All Implemented Interfaces:

Serializable, IBatchBolt<TransactionAttempt>, IComponent

Direct Known Subclasses:

CountingCommitBolt, TransactionalGlobalCount.UpdateGlobalCount, TransactionalWords.BucketCountUpdater, TransactionalWords.KeyedCountUpdater

public abstract class BaseTransactionalBolt
extends BaseBatchBolt<TransactionAttempt>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
BaseTransactionalBolt()

Method Summary

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.coordination.IBatchBolt

execute, finishBatch, prepare

Methods inherited from interface org.apache.storm.topology.IComponent

declareOutputFields, getComponentConfiguration

Constructor Detail

BaseTransactionalBolt

public BaseTransactionalBolt()