UNIFIED WINDOW SUPPORT FOR EVENT STREAM DATA MANAGEMENT
First Claim
1. A computer system including instructions recorded on a computer-readable medium, the system comprising:
- a query handler configured to receive a query from a stream application to be applied against a stream of data including multiple tuples representing events;
a stream window manager configured to express the query in a specification which defines a window including a subset of the tuples, the specification defining content of the window as a range of the tuples having a range attribute over which the content is specified, defining when to update the window using a synchronization attribute specifying a movement of the window over time with respect to the content, and defining an evaluation of the content of the window using an evaluation attribute specifying when to perform the evaluation;
a query translator configured to translate the query including mapping the range attribute, the synchronization attribute, and the evaluation attribute to a stream processing language of a data stream management system (DSMS), to thereby obtain a translated query; and
a DSMS mediator configured to provide the translated query to the DSMS for processing therewith.
2 Assignments
0 Petitions
Accused Products
Abstract
Data stream query mediation may utilize a query handler configured to receive a query from a stream application to be applied against a stream of data including multiple tuples representing events. A stream window manager may be configured to express the query in a specification which defines a window including a subset of the tuples, the specification defining content of the window as a range of the tuples having a range attribute over which the content is specified, defining when to update the window using a synchronization attribute specifying a movement of the window over time with respect to the content, and defining an evaluation of the content of the window using an evaluation attribute specifying when to perform the evaluation. A query translator may be configured to translate the query including mapping the range attribute, the synchronization attribute, and the evaluation attribute to a stream processing language of a data stream management system (DSMS), to thereby obtain a translated query. A DSMS mediator may be configured to provide the translated query to the DSMS for processing therewith.
113 Citations
20 Claims
-
1. A computer system including instructions recorded on a computer-readable medium, the system comprising:
-
a query handler configured to receive a query from a stream application to be applied against a stream of data including multiple tuples representing events; a stream window manager configured to express the query in a specification which defines a window including a subset of the tuples, the specification defining content of the window as a range of the tuples having a range attribute over which the content is specified, defining when to update the window using a synchronization attribute specifying a movement of the window over time with respect to the content, and defining an evaluation of the content of the window using an evaluation attribute specifying when to perform the evaluation; a query translator configured to translate the query including mapping the range attribute, the synchronization attribute, and the evaluation attribute to a stream processing language of a data stream management system (DSMS), to thereby obtain a translated query; and a DSMS mediator configured to provide the translated query to the DSMS for processing therewith. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14)
-
-
15. A computer-implemented method comprising:
-
receiving a query from a stream application to be applied against a stream of data including multiple tuples representing events; expressing the query in a specification which defines a window including a subset of the tuples, the specification defining content of the window as a range of the tuples having a range attribute over which the content is specified, defining when to update the window using a synchronization attribute specifying a movement of the window over time with respect to the content, and defining an evaluation of the content of the window using an evaluation attribute specifying when to perform the evaluation; translating the query including mapping the range attribute, the synchronization attribute, and the evaluation attribute to a stream processing language of a data stream management system, to thereby obtain a translated query; and providing the translated query to the data stream management system for processing therewith. - View Dependent Claims (16, 17)
-
-
18. A computer program product, the computer program product being tangibly embodied on a computer-readable medium and comprising instructions that, when executed, are configured to cause a data processing apparatus to:
-
receive a query from a stream application to be applied against a stream of data including multiple tuples representing events; express the query in a specification which defines a window including a subset of the tuples, the specification defining content of the window as a range of the tuples having a range attribute over which the content is specified, defining when to update the window using a synchronization attribute specifying a movement of the window over time with respect to the content, and defining an evaluation of the content of the window using an evaluation attribute specifying when to perform the evaluation; translate the query including mapping the range attribute, the synchronization attribute, and the evaluation attribute to a stream processing language of a data stream management system, to thereby obtain a translated query; and provide the translated query to the data stream management system for processing therewith. - View Dependent Claims (19, 20)
-
Specification