Package org.apache.storm.st.topology

Interface TestableTopology

All Known Implementing Classes:
SlidingTimeCorrectness, SlidingWindowCorrectness, TumblingTimeCorrectness, TumblingWindowCorrectness
public interface TestableTopology

  • Field Details

    • DUMMY_FIELD

      static final String DUMMY_FIELD
      See Also:

    • TIMEDATA_SLEEP_BETWEEN_EMITS_MS

      static final int TIMEDATA_SLEEP_BETWEEN_EMITS_MS
      See Also:

    • MAX_SPOUT_EMITS

      static final long MAX_SPOUT_EMITS

  • Method Details

    • newTopology

      StormTopology newTopology()

    • getBoltName

      String getBoltName()

    • getBoltExecutors

      int getBoltExecutors()

    • getSpoutName

      String getSpoutName()

    • getSpoutExecutors

      int getSpoutExecutors()