org.apache.storm.state

Interface IStateSpout

All Superinterfaces:

Serializable

All Known Subinterfaces:

IRichStateSpout

public interface IStateSpout
extends Serializable

Method Summary

Modifier and Type	Method and Description
void	close()
void	nextTuple(StateSpoutOutputCollector collector)
void	open(Map conf, TopologyContext context)
void	synchronize(SynchronizeOutputCollector collector)

Method Detail

open

void open(Map conf,
          TopologyContext context)

close

void close()

nextTuple

void nextTuple(StateSpoutOutputCollector collector)

synchronize

void synchronize(SynchronizeOutputCollector collector)