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 <[email protected]> Authored: Sat Feb 20 18:51:58 2016 -0800 Committer: Sriharsha Chintalapani <[email protected]> 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(-) ----------------------------------------------------------------------
