Patent ID: 8909671

Claim:
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.