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