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() Check whether spout is exhausted.
default void	startup() Prepare the spout (globally) before starting the topology.

Method Detail

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.