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/02/21 03:57:04 UTC
[3/4] storm git commit: Merge branch '1.x-min-max' of
http://github.com/satishd/storm into STORM-1511
Merge branch '1.x-min-max' of http://github.com/satishd/storm into STORM-1511
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/db5c0e87
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/db5c0e87
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/db5c0e87
Branch: refs/heads/1.x-branch
Commit: db5c0e87437207160aa4c9d633107724a54f1791
Parents: f6f05af d2089c4
Author: Sriharsha Chintalapani <ha...@hortonworks.com>
Authored: Sat Feb 20 18:51:58 2016 -0800
Committer: Sriharsha Chintalapani <ha...@hortonworks.com>
Committed: Sat Feb 20 18:51:58 2016 -0800
----------------------------------------------------------------------
.../spout/RandomNumberGeneratorSpout.java | 95 +++++++++
.../trident/TridentMinMaxOfDevicesTopology.java | 201 +++++++++++++++++++
.../TridentMinMaxOfVehiclesTopology.java | 180 +++++++++++++++++
.../jvm/org/apache/storm/trident/Stream.java | 121 +++++++++--
.../operation/builtin/ComparisonAggregator.java | 91 +++++++++
.../storm/trident/operation/builtin/Max.java | 37 ++++
.../operation/builtin/MaxWithComparator.java | 51 +++++
.../storm/trident/operation/builtin/Min.java | 36 ++++
.../operation/builtin/MinWithComparator.java | 51 +++++
9 files changed, 850 insertions(+), 13 deletions(-)
----------------------------------------------------------------------