Data processing system for processing interactions

• US 9,830,339 B2
• Filed: 05/04/2015
• Issued: 11/28/2017
• Est. Priority Date: 05/04/2015
• Status: Active Grant

• Current Assignee: Ngdata Products NV
• Original Assignee: Ngdata Products NV
• Inventors: Noels, Steven, Burgelman, Luc, Hamerlinck, Frank
• Primary Examiner(s): Woo, Isaac M
• Application Number:
  US14/703,600
• Publication Number:
  US 20160328422A1
• Time in Patent Office: 939 Days
• Field of Search: 707600-899
• CPC Class Codes: G06F 16/21 Design, administration or maintenance of databases
• CPC Class Codes: G06F 16/24568 Data stream processing; Continuous queries
• CPC Class Codes: G06Q 10/10 Office automation; Time management

Abstract

A data processing system for processing data related to incoming interactions. The data processing system comprises a first configuration object defining a set of metrics; a second configuration object defining a number of aggregation primitives, by analyzing requirements of the set of metrics; a first processing unit adapted for receiving data related to incoming interactions, and adapted for real time calculation of at least one aggregation primitive based on this data taking into account the second configuration object; a data storage element for storing the calculated at least one aggregation primitive without storing raw data related to the incoming interactions; a second processing unit adapted for calculating one or more metrics based on the stored at least one aggregation primitive taking into account the first and the second configuration object.

Claims

1. A computer implemented data processing system for processing data related to incoming interactions, the data processing system comprising:

a first configuration object defining a set of metrics,

a second configuration object defining a number of aggregation primitives, by analyzing requirements of the set of metrics,

a first processing unit adapted for receiving data related to incoming interactions, and adapted for real time calculation of at least one aggregation primitive based on this data taking into account the second configuration object,

a data storage element for storing the calculated at least one aggregation primitive without storing raw data related to the incoming interactions,

a second processing unit adapted for calculating one or more metrics based on the stored at least one aggregation primitive taking into account the first configuration object and the second configuration object,

the data processing system moreover comprising a metric change queue and a write interceptor adapted to intercept storing of the at least one aggregation primitive and to evaluate which metrics may be affected by this aggregation primitive and to add these potentially affected metrics to the metric change queue.

2. A computer implemented data processing system according to claim 1, wherein the first processing unit is adapted for requesting data from an external storage medium and wherein the first processing unit is adapted for calculating at least one aggregation primitive based on the data requested from the external storage medium.

3. A computer implemented data processing system according to claim 1, wherein the first configuration object and the second configuration object are one and the same object.

4. A computer implemented data processing system according to claim 1, wherein the first processing unit and the second processing unit are one and the same processing unit.

5. A computer implemented data processing system according to claim 1, wherein the first processing unit is adapted for subdividing interactions into interaction types.

6. A computer implemented data processing system according to claim 1, wherein the first processing unit is adapted for grouping aggregation primitives based on the extracted data.

7. A computer implemented data processing system according to claim 1, wherein the first processing unit and/or the second processing unit is adapted for monitoring at least one metric.

8. A computer implemented data processing system according to claim 7, wherein the first processing unit and/or the second processing unit is configured to generate an alert based on the monitored at least one metric.

9. A method for processing data related to incoming interactions, the method comprising:

defining a set of metrics in a first configuration object,

defining a number of aggregation primitives in a second configuration object by analyzing requirements of the set of metrics,

running a process wherein the data related to incoming interactions is received and wherein at least one aggregation primitive is calculated in real time based on this data taking into account the second configuration object, and wherein the at least one aggregation primitive is stored in a data storage element without storing raw data related to the incoming interactions, and

running a process wherein requests for the at least one metric are received and wherein the at least one metric is calculated based on the stored at least one aggregation primitive taking into account the first configuration object and the second configuration object, and

intercepting storing of the at least one aggregation primitive and evaluating which metrics may be affected by this aggregation primitive and adding these potentially affected metrics to a metric change queue.