Merge branch 'STORM-676' of http://github.com/satishd/storm into STORM-676
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/b102028c Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/b102028c Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/b102028c Branch: refs/heads/master Commit: b102028ce044892b61fb74a4d8e0c19016e05c40 Parents: a48fae2 1f1b550 Author: Sriharsha Chintalapani <[email protected]> Authored: Sun Mar 27 21:11:05 2016 -0700 Committer: Sriharsha Chintalapani <[email protected]> Committed: Sun Mar 27 21:11:05 2016 -0700 ---------------------------------------------------------------------- examples/storm-starter/pom.xml | 13 +- .../TridentHBaseWindowingStoreTopology.java | 93 +++++++ .../TridentWindowingInmemoryStoreTopology.java | 98 +++++++ .../trident/windowing/HBaseWindowsStore.java | 273 +++++++++++++++++++ .../windowing/HBaseWindowsStoreFactory.java | 55 ++++ storm-core/src/jvm/org/apache/storm/Config.java | 8 + .../jvm/org/apache/storm/trident/Stream.java | 207 ++++++++++++-- .../apache/storm/trident/TridentTopology.java | 4 + .../storm/trident/fluent/UniqueIdGen.java | 14 +- .../storm/trident/operation/builtin/Debug.java | 4 +- .../windowing/AbstractTridentWindowManager.java | 238 ++++++++++++++++ .../windowing/ITridentWindowManager.java | 59 ++++ .../windowing/InMemoryTridentWindowManager.java | 72 +++++ .../trident/windowing/InMemoryWindowsStore.java | 200 ++++++++++++++ .../windowing/InMemoryWindowsStoreFactory.java | 46 ++++ .../StoreBasedTridentWindowManager.java | 217 +++++++++++++++ .../trident/windowing/TridentBatchTuple.java | 42 +++ .../windowing/WindowTridentProcessor.java | 265 ++++++++++++++++++ .../storm/trident/windowing/WindowsState.java | 52 ++++ .../trident/windowing/WindowsStateFactory.java | 40 +++ .../trident/windowing/WindowsStateUpdater.java | 81 ++++++ .../storm/trident/windowing/WindowsStore.java | 78 ++++++ .../trident/windowing/WindowsStoreFactory.java | 35 +++ .../windowing/config/BaseWindowConfig.java | 48 ++++ .../windowing/config/SlidingCountWindow.java | 43 +++ .../windowing/config/SlidingDurationWindow.java | 44 +++ .../windowing/config/TumblingCountWindow.java | 43 +++ .../config/TumblingDurationWindow.java | 42 +++ .../trident/windowing/config/WindowConfig.java | 57 ++++ .../windowing/strategy/BaseWindowStrategy.java | 32 +++ .../strategy/SlidingCountWindowStrategy.java | 59 ++++ .../strategy/SlidingDurationWindowStrategy.java | 60 ++++ .../strategy/TumblingCountWindowStrategy.java | 60 ++++ .../TumblingDurationWindowStrategy.java | 60 ++++ .../windowing/strategy/WindowStrategy.java | 45 +++ .../apache/storm/windowing/TriggerHandler.java | 2 +- .../storm/trident/TridentWindowingTest.java | 105 +++++++ 37 files changed, 2856 insertions(+), 38 deletions(-) ----------------------------------------------------------------------
