Patent ID: 7383253
Filing Date: 2008-06-03
Classification: G06F,Y10S

Abstract:
1. A computer-implemented method of continuously processing a query module that receives data continuously from one or more publishers of data streams in order to push query results as data streams to one or more subscribers continuously, wherein the query module includes one or more input slots on which input data is received, one or more named output slots, and an assembly of connected primitive operators, the method comprising: continuously receiving streaming input data from one or more external publishers, wherein the input data is received on the input slots of the query module; performing primitive operations on the input data, wherein the primitive operators have data dependency relationship between each other and the primitive operations are performed in an order that is consistent with such data dependency relationship; continuously generating output in real time on the output slots of the query module in response to receiving input data on the input slots, wherein the output is the result of performing primitive operations on the input data received on the input slots and the output is in the form of a data stream; and enabling external subscribers to subscribe to such data stream.