Package backtype.storm.transactional

Interface Summary

ICommitter	This marks an IBatchBolt within a transactional topology as a committer.
ICommitterTransactionalSpout<X>
ICommitterTransactionalSpout.Emitter
ITransactionalSpout<T>
ITransactionalSpout.Coordinator<X>
ITransactionalSpout.Emitter<X>

Class Summary

TransactionalSpoutBatchExecutor
TransactionalSpoutCoordinator
TransactionalTopologyBuilder	TODO: check to see if there are two topologies active with the same transactional id essentially want to implement a file lock on top of zk (use ephemeral nodes?) or just use the topology name?
TransactionAttempt