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.
getCoordinator
IPartitionedTransactionalSpout.Coordinator getCoordinator(java.util.Map conf,
TopologyContext context)
getEmitter
IPartitionedTransactionalSpout.Emitter<T> getEmitter(java.util.Map conf,
TopologyContext context)