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 TestableTopology
public String getSpoutName()
getSpoutName
in interface TestableTopology
public int getBoltExecutors()
getBoltExecutors
in interface TestableTopology
public int getSpoutExecutors()
getSpoutExecutors
in interface TestableTopology
public StormTopology newTopology()
newTopology
in interface TestableTopology
Copyright © 2020 The Apache Software Foundation. All rights reserved.