You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by sr...@apache.org on 2015/12/21 05:06:54 UTC
[6/7] storm git commit: Merge branch 'windowing-eventts' of
https://github.com/arunmahadevan/storm into STORM-1187
Merge branch 'windowing-eventts' of https://github.com/arunmahadevan/storm into STORM-1187
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/8129a8bf
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/8129a8bf
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/8129a8bf
Branch: refs/heads/master
Commit: 8129a8bf4f1f28b9f7d3e813f1e3844d9235086f
Parents: 3e76fd5 e764a2b
Author: Sriharsha Chintalapani <ha...@hortonworks.com>
Authored: Sun Dec 20 19:54:12 2015 -0800
Committer: Sriharsha Chintalapani <ha...@hortonworks.com>
Committed: Sun Dec 20 19:54:12 2015 -0800
----------------------------------------------------------------------
docs/documentation/Windowing.md | 91 ++++++
.../storm/starter/SlidingTupleTsTopology.java | 62 ++++
.../storm/starter/SlidingWindowTopology.java | 81 +-----
.../starter/bolt/SlidingWindowSumBolt.java | 80 ++++++
.../storm/starter/spout/RandomIntegerSpout.java | 55 ++++
.../src/clj/backtype/storm/daemon/executor.clj | 2 +
storm-core/src/jvm/backtype/storm/Config.java | 30 +-
.../storm/topology/WindowedBoltExecutor.java | 110 +++++++-
.../storm/topology/base/BaseWindowedBolt.java | 33 +++
.../storm/windowing/CountEvictionPolicy.java | 17 +-
.../storm/windowing/CountTriggerPolicy.java | 11 +-
.../src/jvm/backtype/storm/windowing/Event.java | 8 +
.../jvm/backtype/storm/windowing/EventImpl.java | 13 +
.../storm/windowing/EvictionPolicy.java | 38 ++-
.../storm/windowing/TimeEvictionPolicy.java | 39 ++-
.../storm/windowing/TimeTriggerPolicy.java | 13 +
.../storm/windowing/TriggerHandler.java | 6 +-
.../storm/windowing/WaterMarkEvent.java | 38 +++
.../windowing/WaterMarkEventGenerator.java | 116 ++++++++
.../windowing/WatermarkCountEvictionPolicy.java | 65 +++++
.../windowing/WatermarkCountTriggerPolicy.java | 83 ++++++
.../windowing/WatermarkTimeEvictionPolicy.java | 77 +++++
.../windowing/WatermarkTimeTriggerPolicy.java | 109 ++++++++
.../backtype/storm/windowing/WindowManager.java | 153 +++++++---
.../topology/WindowedBoltExecutorTest.java | 142 ++++++++++
.../windowing/WaterMarkEventGeneratorTest.java | 117 ++++++++
.../storm/windowing/WindowManagerTest.java | 280 +++++++++++++++++--
27 files changed, 1691 insertions(+), 178 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/8129a8bf/storm-core/src/jvm/backtype/storm/Config.java
----------------------------------------------------------------------