Hybrid execution of continuous and scheduled 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;
execute a hybrid query for combining a continuous query and a scheduled database query, the hybrid query refreshed based at least in part on a schedule or a time interval;
generate a stream associated with an event processor configured to provide real-time data;
initialize a query engine with relational data from at least a second source;
identify the continuous query for querying the generated stream;
provide a tactical query to the second source that comprises a relational database, the tactical query configured to pull data elements from the second source based at least in part on a timer;
receive, from the second source, a relational query result based at least in part on the tactical query, the tactical query being provided to a scheduler of the relational database, and the scheduler configured to perform the tactical query on the relational database based at least in part on the schedule;
include the relational data from the second source in the generated stream by automatically pushing the relational data to the continuous query configured to query the generated stream;
enable the query engine to provide a continuous query result based at least in part on an event of the generated stream received by the query engine, the event from a plurality of events of the generated stream including streaming events from the event processor and the relational data; and
provide a user interface configured to display an active visualization based at least in part on data pushed to the query engine.
1 Assignment
0 Petitions
Accused Products
Abstract
Techniques for implementing the hybrid execution of continuous and scheduled queries are provided. In some examples, a query engine may be initialized with relational data from at least a first source. For example, the first source may include a database or other system that can provide historical data. Additionally, the query engine may be enabled to provide query results based at least in part on the relational data from at least the first source and streaming data from at least a second source. In some examples, the second source may be a data stream.
506 Citations
14 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; execute a hybrid query for combining a continuous query and a scheduled database query, the hybrid query refreshed based at least in part on a schedule or a time interval; generate a stream associated with an event processor configured to provide real-time data; initialize a query engine with relational data from at least a second source; identify the continuous query for querying the generated stream; provide a tactical query to the second source that comprises a relational database, the tactical query configured to pull data elements from the second source based at least in part on a timer; receive, from the second source, a relational query result based at least in part on the tactical query, the tactical query being provided to a scheduler of the relational database, and the scheduler configured to perform the tactical query on the relational database based at least in part on the schedule; include the relational data from the second source in the generated stream by automatically pushing the relational data to the continuous query configured to query the generated stream; enable the query engine to provide a continuous query result based at least in part on an event of the generated stream received by the query engine, the event from a plurality of events of the generated stream including streaming events from the event processor and the relational data; and provide a user interface configured to display an active visualization based at least in part on data pushed to the query engine. - View Dependent Claims (2, 3, 4, 5)
-
-
6. 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 execute a hybrid query for combining a continuous query and a scheduled database query, the hybrid query refreshed based at least in part on a schedule or a time interval; instructions that cause the one or more processors to generate a stream associated with a complex event processor configured to provide real-time data; instructions that cause the one or more processors to register the generated stream with a query engine; instructions that cause the one or more processors to receive, by the query engine, a relational query result from a data source; instructions that cause the one or more processors to identify the continuous query for querying the generated stream; instructions that cause the one or more processors to provide a tactical query configured to pull data elements from the data source based at least in part on a timer, the data source comprising a relational database; instructions that cause the one or more processors to receive, from the data source, a relational query result based at least in part on the tactical query, the tactical query being provided to a scheduler of the relational database, and the scheduler configured to perform the tactical query on the relational database based at least in part on the schedule; instructions that cause the one or more processors to include the relational query result from the second source in the generated stream by automatically pushing the relational query result to the continuous query configured to query the generated stream; instructions that cause the one or more processors to provide a continuous query result based at least in part on an event of the generated stream received by the query engine, the event from a plurality of events of the generated stream including streaming events from the complex event processor and the relational query result; and instructions that cause the one or more processors to provide a user interface configured to display an active visualization based at least in part on data pushed to the query engine. - View Dependent Claims (7, 8, 9, 10)
-
-
11. A computer-implemented method, comprising:
-
executing a hybrid query for combining a continuous query and a scheduled database query, the hybrid query refreshed based at least in part on a schedule or a time interval; generating, by a computing system, a stream associated with an event processor configured to provide real-time data; registering, by the computing system, the generated stream with a query engine; identifying the continuous query for querying the registered stream; providing, to a data source that comprises a relational database, a tactical query configured to pull data elements from the data source based at least in part on a timer; receiving, from the data source, a relational query result based at least in part on the tactical query, the tactical query being provided to a scheduler of the relational database, and the scheduler configured to perform the tactical query on the relational database based at least in part on the schedule; including, by the computing system, the relational query result from the data source in the registered stream by automatically pushing the relational query result to the continuous query configured to query the registered stream; providing, by the computing system, a continuous query result based at least in part on an event of the generated stream received by the query engine, the event from a plurality of events of the generated stream including streaming events from the event processor and the relational query result; and providing a user interface configured to display an active visualization based at least in part on data pushed to the query engine. - View Dependent Claims (13, 14)
-
-
12. The computer-implemented method of 11, wherein the query engine is configured based at least in part on a continuous query language.
Specification