Reliance oriented data stream management system

摘要

A computer-implemented method comprises receiving a plurality of data streams into a data stream management system, wherein each data stream is obtained from a data streaming source and a reliance level is associated with each of the data streaming sources. When a continuous query is registered that specifies a reliance level attribute, the query is executed over the plurality of data streams using only those data streams obtained from a data streaming source associated with a suitable reliance level. For example, the reliance level attribute may establish a minimum reliance level, such that data stream having a lesser reliance level are not used. CQL may be enhanced with such an extra attribute which allows end users to specify the desired reliance level when submitting a query.

主权项

1. A computer-implemented method, comprising:
receiving a plurality of data streams into a data stream management system, wherein each data stream is obtained from a data streaming source; associating a reliance level with each of the data streaming sources; registering a query that specifies a minimum reliance level; andexecuting the query over the plurality of data streams using only those data streams obtained from a data streaming source having at least the specified minimum reliance level;
wherein the reliance level associated with at least one of the data streaming sources is based on analysis of previous data received from the at least one data streaming source.