Interface CompletableSpout

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