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 2016/03/28 08:07:20 UTC
[8/9] storm git commit: Merge branch 'STORM-676-1.x' of
http://github.com/satishd/storm into STORM-676-1.x
Merge branch 'STORM-676-1.x' of http://github.com/satishd/storm into STORM-676-1.x
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/b661bf81
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/b661bf81
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/b661bf81
Branch: refs/heads/1.x-branch
Commit: b661bf81ec084ee65c7793746e576dcde5157a3c
Parents: 1783d7a 8c263c7
Author: Sriharsha Chintalapani <ha...@hortonworks.com>
Authored: Sun Mar 27 22:12:26 2016 -0700
Committer: Sriharsha Chintalapani <ha...@hortonworks.com>
Committed: Sun Mar 27 22:12:26 2016 -0700
----------------------------------------------------------------------
examples/storm-starter/pom.xml | 13 +-
.../TridentHBaseWindowingStoreTopology.java | 93 +++++++
.../TridentWindowingInmemoryStoreTopology.java | 98 +++++++
.../trident/windowing/HBaseWindowsStore.java | 275 +++++++++++++++++++
.../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, 2858 insertions(+), 38 deletions(-)
----------------------------------------------------------------------