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

Copyright © 2021 The Apache Software Foundation. All rights reserved.