Package org.apache.storm.st.topology.window

# Class SlidingTimeCorrectness

java.lang.Object
org.apache.storm.st.topology.window.SlidingTimeCorrectness

All Implemented Interfaces:
  `TestableTopology`

public class SlidingTimeCorrectness extends Object implements TestableTopology
Computes sliding window sum.

- ## Field Summary

  ### Fields inherited from interface org.apache.storm.st.topology.TestableTopology

  `DUMMY_FIELD, MAX_SPOUT_EMITS, TIMEDATA_SLEEP_BETWEEN_EMITS_MS`

- ## Constructor Summary

  Constructors
  Constructor
  Description
  `SlidingTimeCorrectness(int windowSec, int slideSec)`

- ## Method Summary

  Modifier and Type
  Method
  Description
  `int`
  `getBoltExecutors()`
  `String`
  `getBoltName()`
  `int`
  `getSpoutExecutors()`
  `String`
  `getSpoutName()`
  `StormTopology`
  `newTopology()`

  ### Methods inherited from class java.lang.Object

  `clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

- ## Constructor Details

  - ### SlidingTimeCorrectness

    public SlidingTimeCorrectness(int windowSec, int slideSec)

- ## Method Details

  - ### getBoltName

    public String getBoltName()
    Specified by:
      `getBoltName` in interface `TestableTopology`

  - ### getSpoutName

    public String getSpoutName()
    Specified by:
      `getSpoutName` in interface `TestableTopology`

  - ### getBoltExecutors

    public int getBoltExecutors()
    Specified by:
      `getBoltExecutors` in interface `TestableTopology`

  - ### getSpoutExecutors

    public int getSpoutExecutors()
    Specified by:
      `getSpoutExecutors` in interface `TestableTopology`

  - ### newTopology

    public StormTopology newTopology()
    Specified by:
      `newTopology` in interface `TestableTopology`