Aggregator

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.

Important

The name of the cache used in this example is demoClusteredCache. Update the cache name according to your own cache.

Pre-Requisite

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 20.200.21.11 and Port 8251.

Install-Module demoCache -AssemblyPath C:\Provider.dll –Server 20.200.21.11 –Port 8251

Aggregator

Important

Pre-Requisite

See Also