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