Implementation of a web scale data fabric
First Claim
1. A method of stream processing machine accelerated and augmented customer data, the method comprising:
- receiving, as data transfer objects, machine accelerated and augmented customer data from one or more business operations client applications via an external computer network, wherein the data transfer objects are (1) received by a message broker component and (2) implemented as an advanced message queuing protocol (AMQP) message with a data transfer object as a payload;
analyzing, by a processor, the received data transfer objects using complex event processing (CEP) configured to inspect at least one attribute of the received data transfer objects for a given window of time;
based on the analyzing, detecting at least one event and applying at least one rule that is specific to business operations client application processing;
semantically classifying text in the received data transfer objects that is specific to the business operations client application processing;
archiving the received data transfer objects in a federated database (FD); and
routing analysis data that is specific to the business operations client application processing to the FD for archiving.
3 Assignments
0 Petitions
Accused Products
Abstract
Methods and systems for processing machine accelerated and augmented customer data using a Web-Scale Data Fabric (WSDF). According to embodiments, the data may be received as data transfer objects from a set of business operations client applications. The data transfer objects may be analyzed using complex event processing (CEP) and, based on the analyzing, rules specific to the business operations client application may be applied. The methods and systems may semantically classify text specific to the business operations client application. A federated database (FD) may archive the receive data transfer objects as well as analysis data specific to the business operations client application.
67 Citations
20 Claims
-
1. A method of stream processing machine accelerated and augmented customer data, the method comprising:
-
receiving, as data transfer objects, machine accelerated and augmented customer data from one or more business operations client applications via an external computer network, wherein the data transfer objects are (1) received by a message broker component and (2) implemented as an advanced message queuing protocol (AMQP) message with a data transfer object as a payload; analyzing, by a processor, the received data transfer objects using complex event processing (CEP) configured to inspect at least one attribute of the received data transfer objects for a given window of time; based on the analyzing, detecting at least one event and applying at least one rule that is specific to business operations client application processing; semantically classifying text in the received data transfer objects that is specific to the business operations client application processing; archiving the received data transfer objects in a federated database (FD); and routing analysis data that is specific to the business operations client application processing to the FD for archiving. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10)
-
-
11. A system for stream processing machine accelerated and augmented customer data, comprising:
-
a memory adapted to store non-transitory computer executable instructions; a federated database (FD); a communication module adapted to communicate with an external computer network; and a processor adapted to interface with the memory, the FD, and the communication module, wherein the processor is configured to execute the non-transitory computer executable instructions to cause the processor to; receive, via the communication module as data transfer objects, machine accelerated and augmented customer data from one or more business operations client applications via the external computer network, wherein the data transfer objects are implemented as an advanced message queuing protocol (AMQP) message with a data transfer object as a payload, analyze the received data transfer objects using complex event processing (CEP) to inspect at least one attribute of the received data transfer objects for a given window of time, based on the analyzing, detect at least one event and apply at least one rule that is specific to business operations client application processing, semantically classify text in the received data transfer objects that is specific to the business operations client application processing, archive the received data transfer objects in the FD, and rout analysis data that is specific to the business operations client application processing to the FD for archiving. - View Dependent Claims (12, 13, 14, 15, 16, 17, 18, 19, 20)
-
Specification