Reorder Functions

Processing data in real-time often involves handling out-of-order events, which can lead to inconsistencies and inaccurate results when performing operations such as aggregation and windowing. To effectively manage out-of-order events and maintain the accuracy of your stream processing, Macrometa GDN Stream Workers offer reorder functions, specifically akslack and kslack.

The akslack and kslack reorder functions are designed to address the challenges associated with out-of-order events in streaming data. They allow you to reorder events based on specified attribute values and apply configurable constraints to ensure that your stream processing pipeline operates efficiently and accurately.

This section, introduces the akslack and kslack reorder functions and demonstrates how to use them within your stream workers to effectively manage out-of-order events in your streaming data.

📄️ akslack (Stream Processor)

Stream processor performs reordering of out-of-order events optimized for a given parameter using AQ-K-Slack algorithm. This is best for reordering events on attributes those are used for aggregations.data .

📄️ kslack (Stream Processor)

Stream processor performs reordering of out-of-order events using K-Slack algorithm.