org.apache.storm.testing

Interface CompletableSpout

All Known Implementing Classes:

FixedTupleSpout, TestEventLogSpout

public interface CompletableSpout

Method Summary

Modifier and Type	Method and Description
default void	clean() Cleanup any global state kept
boolean	isExhausted()
default void	startup() Prepare the spout (globally) before starting the topology

Method Detail

isExhausted

boolean isExhausted()

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