Patent ID: 7480660
Filing Date: 2009-01-20
Classification: G06F,H04L,Y10S

Abstract:
1. A relational stream processing node comprising: A processor and a memory; a configuration interface for changing an operating configuration of said relational stream processing node, wherein said operating configuration includes at least one relational data stream processing operation and at least one a data stream associated with each said at least one relational data stream processing operation, upon which said respective relational stream processing operation will be executed; a control interface for controlling execution thereof including starting and stopping execution of relational stream processing operations, wherein said stopping execution allows changing said operating configuration; an input interface for receiving input streams of tuples from a set of at least one input source, wherein said set of at least one input source includes at least one input source selected from the group consisting of: another relational stream processing node and an external producer; an output interface for sending output streams of tuples to a set of at least one output source, wherein said set of at least one output source includes at least one output source selected from the group consisting of: another relational stream processing node and an external consumer; and a relational stream processing engine operating on said processor for executing said relational stream processing operations including relational stream processing operations consuming said input streams and producing said output streams; wherein said relational stream processing node is interoperable with at least one other relational stream processing node in order to relationally process streams of tuples produced by said external tuple producers and send said streams to said external tuple consumers; and wherein said relational stream processing operations leave said input streams unaltered after execution of said relational stream processing operations on said input streams, and said relational stream processing operations process said input streams so as to perform said relational stream processing operations over said tuples received in said input streams, subsequent to establishing said relational stream processing operations.