Package org.apache.storm.trident.spout
Interface IBatchSpout
- All Superinterfaces:
- ITridentDataSource,- Serializable
- All Known Implementing Classes:
- FixedBatchSpout,- FixedBatchSpout,- RandomNumberGeneratorSpout
- 
Method SummaryModifier and TypeMethodDescriptionvoidack(long batchId) voidclose()voidemitBatch(long batchId, TridentCollector collector) voidopen(Map<String, Object> conf, TopologyContext context) 
- 
Method Details- 
open
- 
emitBatch
- 
ackvoid ack(long batchId) 
- 
closevoid close()
- 
getComponentConfiguration
- 
getOutputFieldsFields getOutputFields()
 
-