You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by ka...@apache.org on 2018/07/10 03:53:36 UTC

[2/2] storm git commit: Merge branch 'STORM-3136' of https://github.com/srdo/storm into STORM-3136-merge

Merge branch 'STORM-3136' of https://github.com/srdo/storm into STORM-3136-merge


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

Branch: refs/heads/master
Commit: 9109b617ba317dc61ce6157ecdf83e14d93488d1
Parents: 35d2ed4 bdcf168
Author: Jungtaek Lim <ka...@gmail.com>
Authored: Tue Jul 10 12:53:25 2018 +0900
Committer: Jungtaek Lim <ka...@gmail.com>
Committed: Tue Jul 10 12:53:25 2018 +0900

----------------------------------------------------------------------
 .../storm/st/topology/TestableTopology.java     |   6 +-
 .../st/topology/window/IncrementingSpout.java   |  75 +++++++
 .../topology/window/SlidingTimeCorrectness.java | 107 +---------
 .../window/SlidingWindowCorrectness.java        |  89 +-------
 .../window/TimeDataIncrementingSpout.java       |  63 ++++++
 .../window/TimeDataVerificationBolt.java        |  69 ++++++
 .../window/TumblingTimeCorrectness.java         | 107 +---------
 .../window/TumblingWindowCorrectness.java       |  89 +-------
 .../st/topology/window/VerificationBolt.java    |  63 ++++++
 .../storm/st/topology/window/data/TimeData.java |  13 +-
 .../st/topology/window/data/TimeDataWindow.java |  82 +++----
 .../apache/storm/st/utils/StringDecorator.java  |   5 +
 .../st/tests/window/SlidingWindowTest.java      |  88 +-------
 .../st/tests/window/TumblingWindowTest.java     |   7 +-
 .../storm/st/tests/window/WindowVerifier.java   | 137 ++++++++++++
 .../storm/st/wrapper/DecoratedLogLine.java      |  67 ++++++
 .../org/apache/storm/st/wrapper/LogData.java    |  66 ------
 .../org/apache/storm/st/wrapper/TopoWrap.java   | 213 +++++++++----------
 18 files changed, 635 insertions(+), 711 deletions(-)
----------------------------------------------------------------------