The Aggregator has been built upon the MapReduce framework and processes distributed data records to return compiled and statistical results. As the name indicates, the Aggregator is used to perform an operation over a range of values to produce a small number of results for analytical purposes. In other words, NCache’s built-in Aggregator is essentially a MapReduce Task, but with a broader set of Aggregation operations. Note that the users can also implement their own Aggregator if required.
The Aggregator basically converts the input data from multiple sources into meaningful key-value pairs and can perform a variety of mathematical operations like summing up values, calculating averages, finding minimum/maximum values etc. to return a single result.
In order to implement Aggregator follow these steps.
The name of the cache used in this example is demoClusteredCache. Update the cache name according to your own cache.
Make sure Aggregator has been implemented as described in the Aggregator section. This assembly will then be deployed using following steps.
Install-Module cmdlet enables the user to deploy provider assemblies from the specified assembly path to the deployment folder named 'deploy' in NCache installed directory.
The following example deploys the assembly for a cache named demoCache on server 184.108.40.206 and Port 8251.
Install-Module demoCache -AssemblyPath C:\Provider.dll –Server 220.127.116.11 –Port 8251