Package org.apache.storm.state

Interface IStateSpout

All Superinterfaces:

Serializable

All Known Subinterfaces:

IRichStateSpout

public interface IStateSpout
extends Serializable

Method Summary

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

Method Details

open

void open(Map<String,Object> conf,
 TopologyContext context)

close

void close()

nextTuple

void nextTuple(StateSpoutOutputCollector collector)

synchronize

void synchronize(SynchronizeOutputCollector collector)