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.