XMPro Aggregate Transformation Agent

Aggregate real-time data in XMPro Data Streams. Learn to group, summarize, and analyze event data using the Aggregation Transformation Agent.

Overview

Aggregation is a computation where the values of multiple rows are grouped together to form a single summary value.

XMPro provides a convenient Transformation that can be used to achieve this easily in a Data Stream. The Agent allows you to aggregate a set of data (e.g. average, min, max, etc.) in a window of time.

This is useful when your data consists of individual events that should be aggregated. The Agent will use a window to buffer these events, group them by the specified column(s), and perform the aggregations so that the outgoing payload is a single event per identifier.

For a simple use case, see the Aggregate Transformation Agent Example.

For a detailed configuration guide, see the Aggregate Transformation Agent Configuration.

Current Version

• Download the Aggregate Transformation Agent v3.16 (Last Updated 25 June 2025)

• Additional Prerequisites: None

Please contact XMPro if you're looking for an older version of this Agent.

Aggregation Transformation Release Notes

Version	Date	Description
3.16	25 Jun 2025	Support the aggregation function Count Distinct Excluding Null function. Repackaged to translate the Agent's properties.
3.15	21 Nov 2023	Support the aggregation function Count Distinct.
3.14	07 Sep 2022	Repackaged to include the Agent's Category.
3.13	11 Feb 2021	Added error endpoint and publishing of any errors.
3.12	23 Jan 2020	Updated to work within a 3.0 .NET Environment.
3.08	04 Sep 2019	Updated System.Reactive and System.Linq.Dynamic.Core.
3.07	15 Aug 2018	Changed Window Size field to drop-down to accept input parameter as its value. It can still accept custom hard-coded value as before.
3.06	15 Aug 2018	Saved options in the Function grid with invalid input parameters are blanked.
3.05	15 Aug 2018	Updated description and URL link.
3.04	17 Jul 2018	Fixed Configuration throwing NullReferenceExceptions when called on an unconfigured object. Fixed Validation throwing KeyNotFoundExceptions when called on an unconfigured object.
3.03	28 May 2018	Removed unsupported configuration options. Outputs for aggregate functions now determine their output type, not defaulting to double. Added validation for function parameters and group by fields. Added try/catch to functions subscribed to observables. Moved remaining start-up logic earlier in the object lifecycle.
3.02	15 May 2018	Fixed VARP/STDEVP functions returning the same result as VAR/STDEV.
3.01	26 Apr 2018	Input Bug Fixes.
3.00	17 Apr 2018	Initial Release