Repository: storm Updated Branches: refs/heads/1.1.x-branch 09d5df90e -> b03f8be66
Improve mention of aggregate() in the partitionAggregate() docs It was not obvious (to me) that aggregate() is covered in detail at another place in the document. That specific section describes the details of the optimization much more exhaustively. Also, it was unclear what the benefits should be compared to, because other aggregator types are only introduced afterwards. Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/b03f8be6 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/b03f8be6 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/b03f8be6 Branch: refs/heads/1.1.x-branch Commit: b03f8be6667541cbe2c05cac2b687de253e0bbcf Parents: 09d5df9 Author: Felix Dreissig <f...@f30.me> Authored: Sat Jan 16 00:48:12 2016 +0100 Committer: Stig Rohde Døssing <s...@apache.org> Committed: Mon Oct 9 20:38:26 2017 +0200 ---------------------------------------------------------------------- docs/Trident-API-Overview.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/b03f8be6/docs/Trident-API-Overview.md ---------------------------------------------------------------------- diff --git a/docs/Trident-API-Overview.md b/docs/Trident-API-Overview.md index ef743db..b602aa1 100644 --- a/docs/Trident-API-Overview.md +++ b/docs/Trident-API-Overview.md @@ -484,7 +484,7 @@ public class Count implements CombinerAggregator<Long> { } ``` -The benefits of CombinerAggregators are seen when you use them with the aggregate method instead of partitionAggregate. In that case, Trident automatically optimizes the computation by doing partial aggregations before transferring tuples over the network. +CombinerAggregators offer high efficiency when used with the aggregate method instead of partitionAggregate ([see below](#aggregation-operations)). A ReducerAggregator has the following interface:
