backtype.storm.state
Interface IStateSpout

All Superinterfaces:
java.io.Serializable
All Known Subinterfaces:
IRichStateSpout

public interface IStateSpout
extends java.io.Serializable


Method Summary
 void close()
           
 void nextTuple(StateSpoutOutputCollector collector)
           
 void open(java.util.Map conf, TopologyContext context)
           
 void synchronize(SynchronizeOutputCollector collector)
           
 

Method Detail

open

void open(java.util.Map conf,
          TopologyContext context)

close

void close()

nextTuple

void nextTuple(StateSpoutOutputCollector collector)

synchronize

void synchronize(SynchronizeOutputCollector collector)