Interface CompletableSpout

All Known Implementing Classes:
FixedTupleSpout, TestEventLogSpout

public interface CompletableSpout
  • Method Summary

    Modifier and Type
    Method
    Description
    default void
    Cleanup any global state kept.
    boolean
    Check whether spout is exhausted.
    default void
    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.