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/17 03:40:06 UTC
[3/4] storm git commit: Merge branch 'min-max' of
http://github.com/satishd/storm into STORM-1511
Merge branch '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/68c87b5e
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/68c87b5e
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/68c87b5e
Branch: refs/heads/master
Commit: 68c87b5eb2d254586fabfc81f5ed7addbb9fdc68
Parents: 82bea75 bc263cb
Author: Sriharsha Chintalapani <ha...@hortonworks.com>
Authored: Tue Feb 16 18:35:03 2016 -0800
Committer: Sriharsha Chintalapani <ha...@hortonworks.com>
Committed: Tue Feb 16 18:35:03 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(-)
----------------------------------------------------------------------