Package org.apache.storm.trident.spout
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.
- 
Nested Class SummaryNested ClassesModifier and TypeInterfaceDescriptionstatic interfacestatic interface
- 
Method SummaryModifier and TypeMethodDescriptiongetCoordinator(Map<String, Object> conf, TopologyContext context) getEmitter(Map<String, Object> conf, TopologyContext context) 
- 
Method Details- 
getCoordinatorIPartitionedTridentSpout.Coordinator<PartitionsT> getCoordinator(Map<String, Object> conf, TopologyContext context) 
- 
getEmitterIPartitionedTridentSpout.Emitter<PartitionsT,PartitionT, getEmitterT> (Map<String, Object> conf, TopologyContext context) 
- 
getComponentConfiguration
- 
getOutputFieldsFields getOutputFields()
 
-