Configurable data windows for archived relations
First Claim
Patent Images
1. A system, comprising:
- a memory storing a plurality of instructions; and
one or more processors that access the memory, wherein the one or more processors execute the plurality of instructions to at least;
identify a continuous query that identifies a data stream;
identify a configurable window size;
generate an archived relation to include at least a portion of historical data and incoming events of the identified data stream that are within a window that corresponds to the configurable window size, the historical data from a previous time associated with the identified data stream;
initialize the continuous query with the archived relation to process at least the portion of the historical data based at least in part on the window size; and
evaluate the archived relation using the continuous query based at least in part on the data stream and the portion of the historical data.
1 Assignment
0 Petitions
Accused Products
Abstract
Techniques for managing configurable data windows for streams and/or archived relations are provided. In some examples, a query that identifies at least a data stream or an archived relation may be identified. Additionally, a configurable window size may be identified. In some instances, the query may be initialized with at least a portion of the historical data based at least in part on the window size. Further, the query may be evaluated based at least in part on the data stream and the portion of the historical data.
-
Citations
20 Claims
-
1. A system, comprising:
-
a memory storing a plurality of instructions; and one or more processors that access the memory, wherein the one or more processors execute the plurality of instructions to at least; identify a continuous query that identifies a data stream; identify a configurable window size; generate an archived relation to include at least a portion of historical data and incoming events of the identified data stream that are within a window that corresponds to the configurable window size, the historical data from a previous time associated with the identified data stream; initialize the continuous query with the archived relation to process at least the portion of the historical data based at least in part on the window size; and evaluate the archived relation using the continuous query based at least in part on the data stream and the portion of the historical data. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11)
-
-
12. 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 receive a continuous query configured to process archived relations, the continuous query including at least one of an identifier of the data stream or an identifier of historical data; instructions that cause the one or more processors to generate a query graph based at least in part on the continuous query; instructions that cause the one or more processors to receive a window size from an entity associated with the data stream; instructions that cause the one or more processors to generate an archived relation to include at least a portion of the historical data and incoming events of the data steam that are within a window that corresponds to the window size, the historical data from a previous time associated with the data stream; instructions that cause the one or more processors to initialize the continuous query with the archived relation to process at least the portion of the historical data based at least in part on the window size; and instructions that cause the one or more processors to evaluate the archived relation using the continuous query based at least in part on the historical data, the window size being based at least in part on the query graph. - View Dependent Claims (13, 14, 15, 16)
-
-
17. A computer-implemented method, comprising:
-
receiving a continuous query configured to process archived relations associated with business event data, the continuous query including an identifier of historical data associated with the stream; generating an archived relation to include at least a portion of the historical data and incoming events of the steam that are within a window that corresponds to the window size, the historical data from a previous time associated with the stream; receiving a window size configured to identify a bounded range of the archived relation to-process; generating a query graph based at least in part on the continuous query, the query graph including at least a node representing an operator of the continuous query; traversing the query graph topographically from a source node of the query graph to identify a stateful operator; initializing the continuous query with the archived relation to process at least the portion of the historical data at the identified stateful operator based at least in part on the window size; and evaluating the archived relation using the continuous query based at least in part on the window size. - View Dependent Claims (20)
-
-
18. The computer-implemented method of 17, wherein the historical data includes business event data from a point in time of the archived relation prior to initializing the continuous query.
-
19. The computer-implemented method of 17, further comprising determining an optimal amount of the historical data with which to initialize the continuous query based at least in part on the operator of the continuous query.
Specification