Patent ID: 8768956

Claim:
A non-transitory computer-readable medium storing instructions for executing a stream data processing method that receives stream data input information as primary information and generates secondary information by acquiring primary information within a predetermined period from among the received primary information, the instructions comprising: managing a plurality of target functions, each of the plurality of target functions relating a first type of processing function from a plurality of first type of processing functions to a second type of processing function from a plurality of second type of processing functions; selecting a target function from the plurality of target functions based on a query; executing the first type of processing function and the second type of processing function on the acquired primary information to generate the secondary information, based on the selected target function; generating a query execution module comprising a plurality of operators for executing the first type of processing function and the second type of processing function based on the selected target function, wherein the generating the query execution module comprises: copying operators from a sliding window operator to a projection operator of the plurality of operators as a copied set of operators; connecting a scan operator of the plurality of operators to a copied sliding window operator in the copied set of operators; generating a join operator before the projection operator and connecting the join operator to a copied projection operator in the copied set of operators; replacing the copied sliding window operator with a jumping window operator; associating the copied projection operator with the second type of processing function; associating the projection operator with the first type of processing function: wherein the first type of processing function is a real-time processing function; wherein the second type of processing function is a batch processing function; and wherein the target function is selected from a function for executing a sliding window, a function for executing a jumping window, and a function for executing a sliding window and a jumping window.