Interface IPartitionedTridentSpout<PartitionsT,PartitionT extends ISpoutPartition,T>

All Superinterfaces:
ITridentDataSource, Serializable
All Known Implementing Classes:
KafkaTridentSpoutTransactional

public interface IPartitionedTridentSpout<PartitionsT,PartitionT extends ISpoutPartition,T> extends ITridentDataSource
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.