Package org.apache.storm.testing
Interface CompletableSpout
-
- All Known Implementing Classes:
FixedTupleSpout
,TestEventLogSpout
public interface CompletableSpout
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description default void
clean()
Cleanup any global state kept.boolean
isExhausted()
Check whether spout is exhausted.default void
startup()
Prepare the spout (globally) before starting the topology.
-