Merge branch 'STORM-2090'

Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/83e1e5b9
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/83e1e5b9
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/83e1e5b9

Branch: refs/heads/master
Commit: 83e1e5b9e99ad44770a59c929fd7105b440333b8
Parents: fe413ab b779ca4
Author: Jungtaek Lim <kabh...@gmail.com>
Authored: Fri Sep 23 10:32:44 2016 +0900
Committer: Jungtaek Lim <kabh...@gmail.com>
Committed: Fri Sep 23 10:32:44 2016 +0900

----------------------------------------------------------------------
 .gitignore                                      |   3 +
 .travis.yml                                     |   8 +-
 integration-test/README.md                      |  59 +++
 integration-test/config/Vagrantfile             | 183 +++++++++
 integration-test/config/cluster.xml             |  96 +++++
 integration-test/config/common.sh               |  21 ++
 integration-test/config/etc-hosts               |  18 +
 integration-test/config/install-storm.sh        |  39 ++
 integration-test/config/install-zookeeper.sh    |  20 +
 integration-test/config/storm.yaml              |  33 ++
 integration-test/pom.xml                        | 250 ++++++++++++
 integration-test/run-it.sh                      |  83 ++++
 .../org/apache/storm/ExclamationTopology.java   |  93 +++++
 .../org/apache/storm/debug/DebugHelper.java     |  39 ++
 .../storm/st/topology/TestableTopology.java     |  30 ++
 .../topology/window/SlidingTimeCorrectness.java | 170 +++++++++
 .../window/SlidingWindowCorrectness.java        | 157 ++++++++
 .../window/TumblingTimeCorrectness.java         | 167 ++++++++
 .../window/TumblingWindowCorrectness.java       | 154 ++++++++
 .../storm/st/topology/window/data/FromJson.java |  22 ++
 .../storm/st/topology/window/data/TimeData.java | 110 ++++++
 .../st/topology/window/data/TimeDataWindow.java |  91 +++++
 .../apache/storm/st/utils/StringDecorator.java  |  37 ++
 .../org/apache/storm/st/utils/TimeUtil.java     |  54 +++
 .../test/java/org/apache/storm/st/DemoTest.java |  85 +++++
 .../apache/storm/st/helper/AbstractTest.java    |  27 ++
 .../apache/storm/st/meta/TestngListener.java    |  97 +++++
 .../st/tests/window/SlidingWindowTest.java      | 187 +++++++++
 .../st/tests/window/TumblingWindowTest.java     |  99 +++++
 .../org/apache/storm/st/utils/AssertUtil.java   |  71 ++++
 .../org/apache/storm/st/wrapper/LogData.java    |  66 ++++
 .../apache/storm/st/wrapper/StormCluster.java   | 118 ++++++
 .../org/apache/storm/st/wrapper/TopoWrap.java   | 378 +++++++++++++++++++
 .../src/test/resources/storm-conf/storm.yaml    |  33 ++
 pom.xml                                         |   3 +
 35 files changed, 3099 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


Reply via email to