org.apache.storm.st.topology

Interface TestableTopology

All Known Implementing Classes:

SlidingTimeCorrectness, SlidingWindowCorrectness, TumblingTimeCorrectness, TumblingWindowCorrectness

public interface TestableTopology

Field Summary

Fields

Modifier and Type	Field and Description
static String	DUMMY_FIELD
static long	MAX_SPOUT_EMITS
static int	TIMEDATA_SLEEP_BETWEEN_EMITS_MS

Method Summary

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

Field Detail

DUMMY_FIELD

static final String DUMMY_FIELD

See Also:

Constant Field Values

TIMEDATA_SLEEP_BETWEEN_EMITS_MS

static final int TIMEDATA_SLEEP_BETWEEN_EMITS_MS

See Also:

Constant Field Values

MAX_SPOUT_EMITS

static final long MAX_SPOUT_EMITS

Method Detail

newTopology

StormTopology newTopology()

getBoltName

String getBoltName()

getBoltExecutors

int getBoltExecutors()

getSpoutName

String getSpoutName()

getSpoutExecutors

int getSpoutExecutors()