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)