Interface IOpaquePartitionedTridentSpout<PartitionsT,PartitionT extends ISpoutPartition,M>

Type Parameters:
M - The type of metadata object passed to the Emitter when emitting a new batch based on a previous batch. This type must be JSON serializable by json-simple.
PartitionsT - The type of metadata object used by the coordinator to describe partitions. This type must be JSON serializable by json-simple.
All Superinterfaces:
ITridentDataSource, Serializable
All Known Implementing Classes:
KafkaTridentSpoutOpaque

public interface IOpaquePartitionedTridentSpout<PartitionsT,PartitionT extends ISpoutPartition,M> extends ITridentDataSource
This defines a transactional spout which does *not* necessarily replay the same batch every time it emits a batch for a transaction id.