backtype.storm.transactional.partitioned
Interface IPartitionedTransactionalSpout<T>

All Superinterfaces:
IComponent, java.io.Serializable
All Known Implementing Classes:
BasePartitionedTransactionalSpout, MemoryTransactionalSpout

public interface IPartitionedTransactionalSpout<T>
extends IComponent

This interface defines a transactional spout that reads its tuples from a partitioned set of brokers. It automates the storing of metadata for each partition to ensure that the same batch is always emitted for the same transaction id. The partition metadata is stored in Zookeeper.


Nested Class Summary
static interface IPartitionedTransactionalSpout.Coordinator
           
static interface IPartitionedTransactionalSpout.Emitter<X>
           
 
Method Summary
 IPartitionedTransactionalSpout.Coordinator getCoordinator(java.util.Map conf, TopologyContext context)
           
 IPartitionedTransactionalSpout.Emitter<T> getEmitter(java.util.Map conf, TopologyContext context)
           
 
Methods inherited from interface backtype.storm.topology.IComponent
declareOutputFields, getComponentConfiguration
 

Method Detail

getCoordinator

IPartitionedTransactionalSpout.Coordinator getCoordinator(java.util.Map conf,
                                                          TopologyContext context)

getEmitter

IPartitionedTransactionalSpout.Emitter<T> getEmitter(java.util.Map conf,
                                                     TopologyContext context)