Repository: storm Updated Branches: refs/heads/master 70d8ba9d5 -> 1a857637e
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/38a32f83 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/38a32f83 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/38a32f83 Branch: refs/heads/master Commit: 38a32f83126fe894a78946504e4eb1cd2c953e8f Parents: cbe1e37 Author: Felix Dreissig <[email protected]> Authored: Sat Jan 16 00:48:12 2016 +0100 Committer: Felix Dreissig <[email protected]> Committed: Mon Oct 9 09:46:20 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/38a32f83/docs/Trident-API-Overview.md ---------------------------------------------------------------------- diff --git a/docs/Trident-API-Overview.md b/docs/Trident-API-Overview.md index a9c9862..b9f074c 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:
