You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pt...@apache.org on 2016/01/27 20:07:47 UTC
[6/7] storm git commit: Merge branch 'windowing-statefulwindow' of
github.com:arunmahadevan/storm into 1.x-branch
Merge branch 'windowing-statefulwindow' of github.com:arunmahadevan/storm into 1.x-branch
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/2ac5c54f
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/2ac5c54f
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/2ac5c54f
Branch: refs/heads/1.x-branch
Commit: 2ac5c54fb1738cc95cd154f9545cde33f555c62c
Parents: 70f1194 596dc3e
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Wed Jan 27 14:04:07 2016 -0500
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Wed Jan 27 14:04:07 2016 -0500
----------------------------------------------------------------------
.../storm/starter/spout/RandomIntegerSpout.java | 5 +-
.../starter/StatefulWindowingTopology.java | 113 ++++++
.../clj/org/apache/storm/daemon/executor.clj | 1 +
storm-core/src/jvm/org/apache/storm/Config.java | 8 +
.../org/apache/storm/state/StateProvider.java | 2 +-
.../storm/topology/IStatefulWindowedBolt.java | 26 ++
.../topology/StatefulWindowedBoltExecutor.java | 372 +++++++++++++++++++
.../apache/storm/topology/TopologyBuilder.java | 18 +
.../storm/topology/WindowedBoltExecutor.java | 37 +-
.../topology/base/BaseStatefulWindowedBolt.java | 150 ++++++++
.../storm/topology/base/BaseWindowedBolt.java | 3 +-
.../storm/windowing/CountTriggerPolicy.java | 10 +-
.../storm/windowing/TimeTriggerPolicy.java | 12 +-
.../apache/storm/windowing/TriggerPolicy.java | 7 +
.../apache/storm/windowing/TupleWindowImpl.java | 21 ++
.../windowing/WaterMarkEventGenerator.java | 13 +-
.../windowing/WatermarkCountTriggerPolicy.java | 10 +-
.../windowing/WatermarkTimeTriggerPolicy.java | 18 +-
.../StatefulWindowedBoltExecutorTest.java | 131 +++++++
.../windowing/WaterMarkEventGeneratorTest.java | 1 +
.../storm/windowing/WindowManagerTest.java | 41 +-
21 files changed, 968 insertions(+), 31 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/2ac5c54f/storm-core/src/jvm/org/apache/storm/Config.java
----------------------------------------------------------------------