Patent ID: 8103655

Claim:
A method of supporting a family of logics defining windows of continuous data streams in a data stream management system, said method comprising: receiving a common software code designed to execute using a set of values as parameters, wherein execution of said common software code with a corresponding set of values for said parameters results in a corresponding one of said family of logics; receiving a query to be executed on a continuous data stream, wherein said query specifies a first set of parametric values corresponding to a desired logic contained in said family of logics; identifying a plurality of data values, among many data values received by said data stream management system, as being received in said continuous data stream; determining, from among said plurality of data values identified as being received in said continuous data stream, a set of data values to be included in a first window corresponding to a first time instant based on said desired logic caused by executing said software code using said first set of parametric values as said set of values, wherein said identifying identifies a first data value as being received in said continuous data stream, wherein said determining comprises: checking whether said first data value is to be included in said window by executing said software code using said first set of parametric values as said set of values; and adding said first data value to said set of data values, only if said first data value is to be included in said first window; and generating an output of said query for said first time instant by processing said query based on said set of data values included in said first window.