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