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 <[email protected]> Authored: Tue Feb 16 18:35:03 2016 -0800 Committer: Sriharsha Chintalapani <[email protected]> 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(-) ----------------------------------------------------------------------
