Package org.apache.storm.state
Interface IStateSpout
-
- All Superinterfaces:
Serializable
- All Known Subinterfaces:
IRichStateSpout
public interface IStateSpout extends Serializable
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidclose()voidnextTuple(StateSpoutOutputCollector collector)voidopen(Map<String,Object> conf, TopologyContext context)voidsynchronize(SynchronizeOutputCollector collector)
-
-
-
Method Detail
-
open
void open(Map<String,Object> conf, TopologyContext context)
-
close
void close()
-
nextTuple
void nextTuple(StateSpoutOutputCollector collector)
-
synchronize
void synchronize(SynchronizeOutputCollector collector)
-
-