Package org.apache.storm.testing
Interface CompletableSpout
- All Known Implementing Classes:
- FixedTupleSpout,- TestEventLogSpout
public interface CompletableSpout
- 
Method Details- 
isExhaustedboolean isExhausted()Check whether spout is exhausted.- Returns:
- true if all the tuples have been completed else false.
 
- 
cleandefault void clean()Cleanup any global state kept.
- 
startupdefault void startup()Prepare the spout (globally) before starting the topology.
 
-