Load shedding in a data stream management system
First Claim
1. A data stream processing system, comprising:
- a data stream management system (DSMS) comprising;
a data store comprising a first memory arranged to store data items received via an input data stream in a data store; and
a first processor comprising;
a continuous query execution circuit configured to execute a continuous query against the received data items to generate an output data stream comprising one or more data items; and
a load shedding circuit configured to execute a load shedding process for discarding some of the data items as received by the DSMS or that have been partially processed by the DSMS;
a DSMS client comprising a second processor and a second memory, the second processor comprising;
a communication circuit configured to receive and process the one or more data items in the output data stream generated by the DSMS; and
a processing circuit configured to execute an action when triggered by the processing of the one or more data items in the output data stream, the action comprising sending a signal, by the DSMS client, to a recipient different from the DSMS client; and
a feedback loop arranged to convey a feedback signal to the DSMS notifying the execution of the action by the DSMS client;
wherein the DSMS is further configured to determine at least one rule governing the load shedding process on the basis of the received feedback signal and the stored data items.
1 Assignment
0 Petitions
Accused Products
Abstract
It is presented a method for notifying at least a first condition in an industrial system by means of a monitoring system in order to draw the attention of an operator monitoring the industrial system to the at least one condition. The method comprises displaying (S1) the first condition in a first portion of a display screen of the monitoring system, determining (S2) by means of eye tracking an area where a user focuses on the display screen, the area where the user focuses differing from the first portion, and alerting (S3) the user of the first condition in order to allow the user to be notified of the first condition in the industrial system. A monitoring system is also presented herein.
8 Citations
42 Claims
-
1. A data stream processing system, comprising:
-
a data stream management system (DSMS) comprising; a data store comprising a first memory arranged to store data items received via an input data stream in a data store; and a first processor comprising; a continuous query execution circuit configured to execute a continuous query against the received data items to generate an output data stream comprising one or more data items; and a load shedding circuit configured to execute a load shedding process for discarding some of the data items as received by the DSMS or that have been partially processed by the DSMS; a DSMS client comprising a second processor and a second memory, the second processor comprising; a communication circuit configured to receive and process the one or more data items in the output data stream generated by the DSMS; and a processing circuit configured to execute an action when triggered by the processing of the one or more data items in the output data stream, the action comprising sending a signal, by the DSMS client, to a recipient different from the DSMS client; and a feedback loop arranged to convey a feedback signal to the DSMS notifying the execution of the action by the DSMS client; wherein the DSMS is further configured to determine at least one rule governing the load shedding process on the basis of the received feedback signal and the stored data items. - View Dependent Claims (2, 3, 4, 5, 6, 7)
-
-
8. A data stream management system (DSMS) comprising:
-
a data store comprising a memory arranged to store data items received via an input data stream; a processor comprising; a continuous query execution circuit configured to execute a continuous query against data items received via the input data stream to generate an output data stream; a learning circuit configured to receive a feedback signal notifying the execution of an action by a client of the DSMS, and determine, using the received feedback signal and stored data items, at least one rule governing a load shedding process for discarding some of the data items as received by the DSMS or that have been partially processed by the DSMS, wherein the action comprises sending a signal, by the DSMS client, to a recipient different from the DSMS client; and a load shedding circuit configured to execute the load shedding process in accordance with the at least one determined rule. - View Dependent Claims (9, 10, 11, 12, 13, 14)
-
-
15. A data stream management system client, comprising a processor and a memory, the processor comprising:
-
a communication circuit configured to receive one or more data items in an output data stream generated by a data stream management system (DSMS); a processing circuit configured to process the received data items in accordance with stored processing logic and execute an action when triggered by the processing of one or more of the received data items, the action comprising sending a signal, by the DSMS client, to a recipient different from the DSMS client; and a feedback signal generation circuit configured to generate a feedback signal notifying the execution of an action by the processing circuit; wherein the communication circuit is configured to transmit the generated feedback signal to the DSMS. - View Dependent Claims (16, 17, 18, 19, 20)
-
-
21. A method of processing stream data in a data stream processing system comprising a data stream management system (DSMS) and a DSMS client, the method comprising:
-
the DSMS storing data items received via an input data stream in a data store; the DSMS executing a continuous query against the received data items to generate an output data stream comprising one or more data items; the DSMS client receiving and processing the one or more data items in the output data stream generated by the DSMS, and executing an action when triggered by the processing of the one or more data items in the output data stream, the action comprising sending a signal, by the DSMS client, to a recipient different from the DSMS client; the DSMS being provided with a feedback signal notifying the execution of the action by the DSMS client; the DSMS determining, on the basis of the provided feedback signal and stored data items, at least one rule governing a load shedding process for discarding some of the data items as received by the DSMS or that have been partially processed by the DSMS; and the DSMS executing the load shedding process in accordance with the at least one determined rule. - View Dependent Claims (22, 23, 24, 25, 26, 27)
-
-
28. A method of processing stream data in a data stream management system (DSMS), the method comprising:
-
receiving data items in an input data stream; storing the received data items in a data store; executing a continuous query against the received data items to generate an output data stream; receiving a feedback signal notifying the execution of an action by a client of the DSMS, the action comprising sending a signal, by the DSMS client, to a recipient different from the DSMS client; determining, on the basis of the received feedback signal and the stored data items, at least one rule governing a load shedding process for discarding some of the data items as received by the DSMS or that have been partially processed by the DSMS; and executing the load shedding process in accordance with the at least one determined rule. - View Dependent Claims (29, 30, 31, 32, 33)
-
-
34. The method of claim to 28, further comprising receiving, as the feedback signal, the signal sent by the DSMS client in execution of the action.
-
35. A method of processing stream data in a data stream management system client, the method comprising:
-
receiving data items in an output data stream generated by a data stream management system (DSMS); processing the received data items by a processing module in accordance with stored processing logic and executing an action when triggered by the processing of one of more of the received data items, the action comprising sending a signal, by the DSMS client, to a recipient different from the DSMS client; generating a feedback signal notifying the execution of an action by the processing module; and transmitting the generated feedback signal to the DSMS. - View Dependent Claims (36, 37, 38, 39, 40)
-
-
41. A computer program product stored in a non-transitory computer readable medium for controlling a data stream management system (DSMS), the computer program product comprising computer program instructions which, when executed by a processor in the DSMS, cause the processor to:
-
receive data items in an input data stream; store the received data items in a data store; execute a continuous query against the received data items to generate an output data stream; receive a feedback signal notifying the execution of an action by a client of the DSMS, the action comprising sending a signal, by the DSMS client, to a recipient different from the DSMS client; determine, on the basis of the received feedback signal and the stored data items, at least one rule governing a load shedding process for discarding some of the data items as received by the DSMS or that have been partially processed by the DSMS; and execute the load shedding process in accordance with the at least one determined rule.
-
-
42. A computer program product stored in a non-transitory computer readable medium for controlling a data stream management system client, the computer program product comprising computer program instructions which, when executed by a processor in the data stream management system client, cause the processor to:
-
receive data items in an output data stream generated by a data stream management system (DSMS); process the received data items by a processing module in accordance with stored processing logic and executing an action when triggered by the processing of one of more of the received data items, the action comprising sending a signal, by the DSMS client, to a recipient different from the DSMS client; generate a feedback signal notifying the execution of an action by the processing module; and transmit the generated feedback signal to the DSMS.
-
Specification