Package org.apache.storm.testing

# Interface CompletableSpout

All Known Implementing Classes:
  `FixedTupleSpout`, `TestEventLogSpout`

public interface CompletableSpout

- ## Method Summary

  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.

- ## 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.