Evaluating event-generated data using append-only tables
First Claim
1. A method for evaluating an N-way join of multiple sets of records, the method comprising:
- analyzing a plurality of correlation conditions that are defined in the N-way join, wherein the plurality of correlation conditions indicate a group of attributes from the multiple sets of records;
based on the analysis of the plurality of correlation conditions, determining a maximal partitioning key for the N-way join, wherein the maximal partitioning key includes one or more attributes from the group of attributes indicated in the plurality of correlation conditions;
automatically splitting the multiple sets of records into two or more sub-sequences of records based on unique values in the one or more attributes, of the maximal partitioning key, that are included in the records of the multiple sets of records; and
processing the two or more sub-sequences of records in parallel;
wherein the method is performed by one or more computer systems.
0 Assignments
0 Petitions
Accused Products
Abstract
Techniques are provided for evaluating base events, compound events, and logical update events in an event processing system. In one embodiment, the base events, compound events, and logical update events are definitions in a particular syntax language that specify conditions for evaluating input event data. In this embodiment, base event definitions are evaluated over the input event data; logical update event definitions are evaluated by determining whether the effect of any earlier event is changed by the arrival of a new event; and compound event definitions are evaluated over records representing events that have been selected by evaluating the base event definitions over the input event data.
-
Citations
20 Claims
-
1. A method for evaluating an N-way join of multiple sets of records, the method comprising:
-
analyzing a plurality of correlation conditions that are defined in the N-way join, wherein the plurality of correlation conditions indicate a group of attributes from the multiple sets of records; based on the analysis of the plurality of correlation conditions, determining a maximal partitioning key for the N-way join, wherein the maximal partitioning key includes one or more attributes from the group of attributes indicated in the plurality of correlation conditions; automatically splitting the multiple sets of records into two or more sub-sequences of records based on unique values in the one or more attributes, of the maximal partitioning key, that are included in the records of the multiple sets of records; and processing the two or more sub-sequences of records in parallel; wherein the method is performed by one or more computer systems. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10)
-
-
11. A non-transitory machine-readable storage medium storing one or more sequences of instructions for evaluating an N-way join of multiple sets of records wherein, when executed by one or more processors, the one or more sequences of instructions cause the one or more processors to perform steps comprising:
-
analyzing a plurality of correlation conditions that are defined in the N-way join, wherein the plurality of correlation conditions indicate a group of attributes from the multiple sets of records; based on the analysis of the plurality of correlation conditions, determining a maximal partitioning key for the N-way join, wherein the maximal partitioning key includes one or more attributes from the group of attributes indicated in the plurality of correlation conditions; automatically splitting the multiple sets of records into two or more sub-sequences of records based on unique values in the one or more attributes, of the maximal partitioning key, that are included in the records of the multiple sets of records; and processing the two or more sub-sequences of records in parallel. - View Dependent Claims (12, 13, 14, 15, 16, 17, 18, 19, 20)
-
Specification