public class TumblingWindowCorrectness extends Object implements TestableTopology
Computes sliding window sum.
DUMMY_FIELD, MAX_SPOUT_EMITS, TIMEDATA_SLEEP_BETWEEN_EMITS_MS
Constructor and Description |
---|
TumblingWindowCorrectness(int tumbleSize) |
Modifier and Type | Method and Description |
---|---|
int |
getBoltExecutors() |
String |
getBoltName() |
int |
getSpoutExecutors() |
String |
getSpoutName() |
StormTopology |
newTopology() |
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.