Mechanism to chain continuous queries
First Claim
Patent Images
1. A system, comprising:
- a memory storing a plurality of instructions; and
one or more processors configured to access the memory, wherein the one or more processors are further configured to execute the plurality of instructions to at least;
process a first continuous query on an archived relation of business event data, the archived relation of business event data comprising a first data source for the first continuous query and comprising an unordered, time-varying set of tuples associated with the first data source;
collect first results of the first continuous query during a time interval;
store the first results of the first continuous query in a first data object for at least a time period, wherein the time period is determined based at least in part on performance criteria associated with the first data object;
implement a second continuous query configured to only process “
insert”
instructions found within the first results stored in the first data object, the first results comprising a second data source for the second continuous query, and wherein processing only “
insert”
instructions comprises not processing other instructions found within the first results stored in the first data object;
collect second results from processing the second continuous query;
store the second results of the second continuous query in a second data object;
implement a pattern match query on the second results stored in the second data object;
perform trend analysis on the pattern match query results;
provide, for display by a user interface, a mapping of the trend analysis to a visualization;
identifying a pattern corresponding to a performance indicator from the trend analysis; and
provide an alert in the user interface based at least in part on the pattern identified from the trend analysis.
1 Assignment
0 Petitions
Accused Products
Abstract
Techniques for implementing mechanisms for chaining continuous queries are provided. In some examples, results of a first continuous query may be stored in a data object. For example, the first continuous query may be configured to process business event data and store the results in the data object. Additionally, a second continuous query may then be processed based at least in part on the results stored in the data object.
-
Citations
13 Claims
-
1. A system, comprising:
-
a memory storing a plurality of instructions; and one or more processors configured to access the memory, wherein the one or more processors are further configured to execute the plurality of instructions to at least; process a first continuous query on an archived relation of business event data, the archived relation of business event data comprising a first data source for the first continuous query and comprising an unordered, time-varying set of tuples associated with the first data source; collect first results of the first continuous query during a time interval; store the first results of the first continuous query in a first data object for at least a time period, wherein the time period is determined based at least in part on performance criteria associated with the first data object; implement a second continuous query configured to only process “
insert”
instructions found within the first results stored in the first data object, the first results comprising a second data source for the second continuous query, and wherein processing only “
insert”
instructions comprises not processing other instructions found within the first results stored in the first data object;collect second results from processing the second continuous query; store the second results of the second continuous query in a second data object; implement a pattern match query on the second results stored in the second data object; perform trend analysis on the pattern match query results; provide, for display by a user interface, a mapping of the trend analysis to a visualization; identifying a pattern corresponding to a performance indicator from the trend analysis; and provide an alert in the user interface based at least in part on the pattern identified from the trend analysis. - View Dependent Claims (2, 3, 4, 5, 6, 7)
-
-
8. A computer-readable memory storing a plurality of instructions executable by one or more processors, the plurality of instructions comprising:
-
instructions that cause the one or more processors to process a first continuous query on an archived relation of business event data associated with a user to collect first results during a time interval, the archived relation of business event data comprising a first data source for the first continuous query and comprising an unordered, time-varying set of tuples associated with the first data source; instructions that cause the one or more processors to store the first results in memory as a first data object for at least a time period, wherein the time period is determined based at least in part on performance criteria associated with the first data object; instructions that cause the one or more processors to implement, based at least in part on receipt of a trigger, a second continuous query configured to only process “
insert”
instructions found within the first results of the first data object, the first results comprising a second data source for the second continuous query, and wherein processing only “
insert”
instructions comprises not processing other instructions found within the first results stored in the first data object;instructions that cause the one or more processors to collect second results from the processing of the second continuous query; instructions that cause the one or more processors to store the second results of the second continuous query in a second data object instructions that cause the one or more processors to implement a pattern match query on the second results stored in the second data object; instructions that cause the one or more processors to perform trend analysis on the pattern match query results; instructions that cause the one or more processors to provide, for display by a user interface, a mapping of the trend analysis to a visualization; instructions that cause the one or more processors to identify a pattern corresponding to a performance indicator from the trend analysis; and instructions that cause the one or more processors to provide an alert in the user interface based at least in part on the pattern identified from the trend analysis. - View Dependent Claims (9, 10, 11)
-
-
12. A computer-implemented method, comprising:
-
processing a first continuous query on archived relation of business event data associated with a user to collect first results during a time interval, the archived relation of business event data comprising a first data source for the first continuous query and comprising an unordered, time-varying set of tuples associated with the first data source; storing the first results in memory as a first data object for at least a time period, wherein the time period is determined based at least in part on performance criteria associated with the first data object; implementing, based at least in part on receipt of a trigger, a second continuous query configured to only process “
insert”
instructions found within the first results stored in the first data object to collect second results, the first results comprising a second data source for the second continuous query, and wherein processing only “
insert”
instructions comprises not processing other instructions found within the first results stored in the first data object;collecting second results from the processing of the second continuous query; storing the second results of the second continuous query in a second data object; implementing a pattern match query on the second results stored in the second data object; performing trend analysis on the pattern match query results; providing, for display by a user interface of the user, a mapping of the trend analysis to a visualization; identifying a pattern corresponding to a performance indicator from the trend analysis; and providing an alert to the user based at least in part on the pattern identified from the trend analysis. - View Dependent Claims (13)
-
Specification