Generic query templates for complex event processing and data stream systems
First Claim
1. A computer-implemented method for generating queries with a number of input streams from a generic query template, the method comprising:
- sending, with a processor, a selected generic query template and an at least one entered query input stream to a query manager, wherein the generic query template includes at least one predefined query string having placeholders at designated alterable fields of the generic query template, each placeholder of the generic query template having a mandatory designation or an optional designation;
registering, with the query manager, the selected generic query template and the at least one entered query input stream;
generating, with the query manager, at least one query output stream based on the registered generic query template and the at least one registered query input stream;
loading, with the query manger, the registered generic query template with the at least one query output stream and the at least one registered query input stream;
parsing, with the query manager, the loaded generic query template, comprising;
retrieving, with the query manager, a query template orchestration configuration for the loaded generic query template from the database; and
upon determining, with the query manager, that instructions are available in the query template orchestration configuration,executing, with the query manager, the instructions in the query template orchestration configuration, wherein each step of the instructions is executed for each of the at least one query input stream; and
forming a deployable query for instantiation within a data stream management system from substituting, with the query manager, the placeholders with the at least one query output stream and the at least one registered query input stream.
2 Assignments
0 Petitions
Accused Products
Abstract
Systems and methods provide for queries with an arbitrary number of input streams to be created from a generic query template, during runtime, based on, for example, configuration parameters provided by the system or a user. The generic query templates include a generic query template string, query template segments, and an orchestration mechanism for automatic query template generation. The systems and methods of the present invention provide for the substitution of concrete input streams, counters (e.g., stream indices) and query template segments (which can include further placeholders) into the generic query templates. Further, the input placeholders of the generic query template provide for any part of the query template to be substituted with arbitrary logic. Also, the orchestration process is query language independent and can be applied (and extended) for any query language.
-
Citations
20 Claims
-
1. A computer-implemented method for generating queries with a number of input streams from a generic query template, the method comprising:
-
sending, with a processor, a selected generic query template and an at least one entered query input stream to a query manager, wherein the generic query template includes at least one predefined query string having placeholders at designated alterable fields of the generic query template, each placeholder of the generic query template having a mandatory designation or an optional designation; registering, with the query manager, the selected generic query template and the at least one entered query input stream; generating, with the query manager, at least one query output stream based on the registered generic query template and the at least one registered query input stream; loading, with the query manger, the registered generic query template with the at least one query output stream and the at least one registered query input stream; parsing, with the query manager, the loaded generic query template, comprising; retrieving, with the query manager, a query template orchestration configuration for the loaded generic query template from the database; and upon determining, with the query manager, that instructions are available in the query template orchestration configuration, executing, with the query manager, the instructions in the query template orchestration configuration, wherein each step of the instructions is executed for each of the at least one query input stream; and forming a deployable query for instantiation within a data stream management system from substituting, with the query manager, the placeholders with the at least one query output stream and the at least one registered query input stream. - View Dependent Claims (2, 3, 4, 5, 6, 7)
-
-
8. A non-transitory computer readable medium having program instructions for generating queries with a number of input streams from a generic query template, wherein execution of the program instructions by one or more processor of a computer system causes one or more processor to carry out the steps of:
-
sending a selected generic query template and an at least one entered query input stream to a query manager, wherein the generic query template includes at least one predefined query string having placeholders at designated alterable fields of the generic query template, each placeholder of the generic query template having a mandatory designation or an optional designation; registering, with the query manager, the selected generic query template and the at least one entered query input stream; generating, with the query manager, at least one query output stream based on the registered generic query template and the at least one registered query input stream; loading, with the query manager, the registered generic query template with the at least one query output stream and the at least one registered query input stream; parsing, with the query manager, the loaded generic query template, comprising; retrieving, with the query manager, a query template orchestration configuration for the loaded generic query template from the database; and upon determining, with the query manager, that instructions are available in the query template orchestration configuration, executing, with the query manager, the instructions in the query template orchestration configuration, wherein each step of the instructions is executed for each of the at least one query input stream; and forming a deployable query for instantiation within a data stream management system from substituting, with the query manager, the placeholders with the at least one query output stream and the at least one registered query input stream. - View Dependent Claims (9, 10, 11, 12, 13)
-
-
14. A system directed to generating queries with an arbitrary number of input streams from a generic query template, comprising:
-
a database; a data stream management system; a query manager; a processor, wherein the processor performs the steps of; sending a selected generic query template and at least one entered query input stream to the query manger, wherein the generic query template includes at least one predefined query string having placeholders at designated alterable field of the generic query, each placeholder of the generic query template having a mandatory designation or an optional designation; registering, with the query manager, the selected generic query template and the at least one entered query input stream; generating, with the query manager, at least one query output stream based on the registered generic query template and the at least one registered query input stream; loading, with the query manager, the registered generic query template with the at least one query output stream and the at least one registered query input stream; parsing, with the query manager, the loaded generic query template, comprising; retrieving, with the query manager, a query template orchestration configuration of the loaded generic query template from the database; and upon determining, with the query manager, that instructions are available in the query template orchestration configuration, executing, with the query manager, the instructions in the query template orchestration configuration, wherein each step of the instructions is executed for each of the at least one query input stream; forming a deployable query for instantiation within the data stream management system from substituting, within the query manager, the placeholders with the at least one query output stream and the at least one registered query input stream; and deploying the deployable query within the data stream management system for application against stream data. - View Dependent Claims (15, 16, 17, 18, 19, 20)
-
Specification