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