Subscription handling and in-memory alignment of unsynchronized real-time data streams

1. A method for subscription handling and in-memory alignment of unsynchronized real-time data streams and comprising:

receiving a subscription comprising a signal identifier, the signal identifier being associated with a value that is required for handling the subscription;

receiving unsynchronized data points, each data point comprising an actual time of measurement (ATM) timestamp, the signal identifier and the value;

handling the subscription using the unsynchronized data points by:

aligning the unsynchronized data points in predefined time slots, the predefined time slots comprising masks, wherein a first predefined time slots comprises first values of the unsynchronized data points for a first ATM timestamp and a first mask for validation of the first values of the first ATM timestamp;

executing the subscription using the first values of the first ATM timestamp; and

returning the first predefined time slot to a memory pool for usage as a second predefined time slot for unsynchronized data points of a second ATM timestamp.

2. The method of claim 1 , wherein the signal identifier indicates signals required for handling the subscription.

3. The method of claim 1 , wherein the predefined time slots comprise cells, and wherein the ATM timestamp and the signal identifier are used to deterministically find a column and a row identifying a cell for insertion.

4. The method of claim 1 , wherein handling the subscription further comprises:

when a timeout is detected:

moving the subscription to a next available row, and

returning unhandled rows to a position of an oldest subscription after each cycle.

5. The method of claim 1 , wherein handling the subscription further comprises:

when an overflow is detected:

moving the subscription to an earliest row within a buffer window; and

returning rows outside the buffer window to the memory pool.

6. The method of claim 1 , wherein handling the subscription further comprises:

filling in a data gap in the first predefined time slot for the first ATM timestamp in response to missing valid first values such that the first mask of the first predefined time slot indicates that the first values are valid.

7. The method of claim 6 , further comprising detecting the data gap when a later value corresponding to a later ATM timestamp is received, and

wherein filling in the data gap comprises inserting a value corresponding to one of: an immediately previous value, an average of all values, an interpolated value, or an average of the immediately previous value and an immediately following value, for a signal where the data gap is detected.

8. A data processing system comprising:

an accessible memory; and

a processor coupled to the accessible memory, the processor configured to:

receive a subscription comprising a signal identifier, the signal identifier being associated with a value that is required for handling the subscription;

receive unsynchronized data points, each data point comprising an actual time of measurement (ATM) timestamp, the signal identifier and the value,

handle the subscription using the unsynchronized data points:

align the unsynchronized data points in predefined time slots, the predefined time slots comprising masks, wherein a first predefined timeslot comprises first values for a first ATM timestamp and a first mask for validation of the first values of the first ATM timestamp;

execute the subscription using the first values of the first ATM timestamp; and

return the first predefined time slot to a memory pool for usage as a second predefined timeslot for unsynchronized data points of a second ATM timestamp.

9. The data processing system of claim 8 , wherein the signal identifier indicates signals required for handling the subscription.

10. The data processing system of claim 8 , wherein the predefined time slots comprise cells, and wherein the ATM timestamp and the signal identifier are used to deterministically find a column and a row identifying a cell for insertion of a value.

11. The data processing system of claim 8 , wherein to handle the subscription further comprises:

when a timeout is detected, the processor is further configured to:

move the subscription to a next available row, and

return unhandled rows to a position of an oldest subscription after each cycle.

12. The data processing system of claim 8 , wherein to handle the subscription further comprises:

when an overflow is detected, the processor is further configured to:

move the subscription to an earliest row within a buffer window; and

return rows outside the buffer window to the memory pool.

13. The data processing system of claim 8 , wherein to handle the subscription further comprises to fill in a data gap in the first predefined time slot for the first ATM timestamp in response to missing valid first values such that the first mask of the first predefined time slot indicates that the first values are valid.

14. The data processing system of claim 13 , wherein the processor is further configured to detect the data gap when a later value corresponding to a later ATM timestamp is received,

wherein to fill in the data gap comprises to insert a value corresponding to one of: an immediately previous value, an average of all values, an interpolated value, or an average of the immediately previous value and an immediately following value, for a signal where the data gap is detected.

15. A non-transitory computer-readable medium encoded with executable instructions that, when executed, cause a processor to:

receive a subscription comprising a signal identifier, the signal identifier being associated with a value that is required for handling the subscription;

receive unsynchronized data points, each data point comprising an actual time of measurement (ATM) timestamp, the signal identifier and the value,

handle the subscription using the unsynchronized data points:

align the unsynchronized data points in predefined time slots, the predefined time slots comprising masks, wherein a first predefined timeslot comprises first values for a first ATM timestamp and a first mask for validation of the first values of the first ATM timestamp;

execute the subscription using the first values of the first ATM timestamp; and

return the first predefined time slot to a memory pool for usage as a second predefined timeslot for unsynchronized data points of a second ATM timestamp.

16. The non-transitory computer-readable medium of claim 15 , wherein the signal identifier indicates signals required for handling the subscription.

17. The non-transitory computer-readable medium of claim 15 , wherein the predefined time slots comprise cells, and wherein the ATM timestamp and the signal identifier are used to deterministically find a column and a row identifying a cell for insertion of a value.

18. The non-transitory computer-readable medium of claim 15 , wherein to handle the subscription further comprises:

when a timeout is detected, the processor is further configured to:

move the subscription to a next available row, and

return unhandled rows to a position of an oldest subscription after each cycle.

19. The non-transitory computer-readable medium of claim 15 , wherein to handle the subscription further comprises to fill in a data gap in the first predefined time slot for the first ATM timestamp in response to missing valid first values such that the first mask of the first predefined time slot indicates that the first values are valid.

20. The non-transitory computer-readable medium of claim 19 , wherein the instructions further cause the processor to detect the data gap when a later value corresponding to a later ATM timestamp is received, and

wherein to fill in the data gap comprises to insert a value corresponding to one of: an immediately previous value, an average of all values, an interpolated value, or an average of the immediately previous value and an immediately following value, for a signal where the data gap is detected.