public class SlidingWindowCorrectness extends Object implements TestableTopology
Computes sliding window sum.
DUMMY_FIELD, MAX_SPOUT_EMITS, TIMEDATA_SLEEP_BETWEEN_EMITS_MS| Constructor and Description |
|---|
SlidingWindowCorrectness(int windowSize,
int slideSize) |
| Modifier and Type | Method and Description |
|---|---|
int |
getBoltExecutors() |
String |
getBoltName() |
int |
getSpoutExecutors() |
String |
getSpoutName() |
StormTopology |
newTopology() |
public SlidingWindowCorrectness(int windowSize,
int slideSize)
public String getBoltName()
getBoltName in interface TestableTopologypublic String getSpoutName()
getSpoutName in interface TestableTopologypublic int getBoltExecutors()
getBoltExecutors in interface TestableTopologypublic int getSpoutExecutors()
getSpoutExecutors in interface TestableTopologypublic StormTopology newTopology()
newTopology in interface TestableTopologyCopyright © 2021 The Apache Software Foundation. All rights reserved.