Package org.apache.storm.state
Interface IStateSpout
- All Superinterfaces:
- Serializable
- All Known Subinterfaces:
- IRichStateSpout
- 
Method SummaryModifier and TypeMethodDescriptionvoidclose()voidnextTuple(StateSpoutOutputCollector collector) voidopen(Map<String, Object> conf, TopologyContext context) voidsynchronize(SynchronizeOutputCollector collector) 
- 
Method Details- 
open
- 
closevoid close()
- 
nextTuple
- 
synchronize
 
-