ENRICHING EVENTS WITH DYNAMICALLY TYPED BIG DATA FOR EVENT PROCESSING
First Claim
1. A method, comprising:
- creating an event processing network to represent a data store;
creating, in the event processing network, a table component that represents a data store event of the data store; and
for a particular event in an event stream, executing a processor of the event processing network using the table component as an external relation source to perform operations comprising;
selecting, from the data store, particular data that corresponds to the particular event; and
adding the particular data to the particular event.
1 Assignment
0 Petitions
Accused Products
Abstract
Some event ordering requirements can be determined based on continuous event processing queries. Other event ordering requirements can be determined based on distribution flow types being used to distribute events from event streams to node executing the queries. Events from event streams can be ordered according to ordering semantics that are based on a combination of all of these event ordering requirements. Additionally, virtual computing nodes can be associated with constraints, and computing processors can be associated with capabilities. Virtual computing nodes for processing event streams can be assigned to execute on various computing processors based on both these constraints and capabilities. Additionally, for each of several events in an event stream, a ratio between a total latency and a communication latency can be for determined. Based on an average of these ratios, a quantity of reducing nodes that will be involved in a map-reduce operation can be selected.
-
Citations
20 Claims
-
1. A method, comprising:
-
creating an event processing network to represent a data store; creating, in the event processing network, a table component that represents a data store event of the data store; and for a particular event in an event stream, executing a processor of the event processing network using the table component as an external relation source to perform operations comprising; selecting, from the data store, particular data that corresponds to the particular event; and adding the particular data to the particular event. - View Dependent Claims (2, 3, 4, 5, 6)
-
-
7. A computer-readable medium storing computer-executable instructions that, when executed by one or more processors, configures one or more computer systems to perform at least:
-
instructions that cause the one or more processors to create a table component that represents a data store event of a data store; and instructions that cause the one or more processors to implement an engine of an event processing network using the table component as an external relation source to perform; instructions that cause the one or more processors to select, from the data store, particular data that corresponds to a particular event of an event stream; and instructions that cause the one or more processors to add the particular data to the particular event. - View Dependent Claims (8, 9, 10, 11, 12, 13, 14)
-
-
15. A system, comprising:
-
a memory storing a plurality of instructions; and a processor configured to access the memory, the processor further configured to execute the plurality of instructions to at least; create a table component that represents a data store event of a data store; and implement an engine of an event processing network using the table component as an external relation source to; select, from the data store, particular data that corresponds to a particular event of an event stream; and add the particular data to the particular event. - View Dependent Claims (16, 17, 18, 19, 20)
-
Specification