US 7,480,660 B1Granted

Method for distributed RDSMS

OwnerDamian Blackinventor

Life of this patent

Estimating the term…

Loading patent…

Abstract

Methods and products for processing streams of data records using at least one data stream processing program executing on at least one data processing device and communicating with one another through data communication interfaces to form a network of data stream processing programs. In at least one embodiment, a method includes holding and maintaining information to record a configuration history, processing streams of data records with a plurality of data stream processing programs together functioning as a stream processing system, receiving input streams of data records by the data stream processing programs over the data communication interfaces, sending output streams of data records by the data stream processing programs over the data communication interfaces, and interoperating internal data producer/publisher programs with internal data consumer/producer programs in accordance with a current configuration in order to perform the sending and receiving.

Claims25

Dependent claims

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.

8 more elements

A method of processing streams of tuples using at least one a relational data stream processing program executing on at least one data processing device and communicating with one another through data communication interfaces to form a network of relational data stream processing programs, said method comprising:

(a) holding and maintaining information to record a configuration history, including at least a current configuration, of said relational data stream processing programs including currently executing relational stream processing operations of said relational data stream processing programs and currently existing relational stream processing queries;
(b) processing said streams of tuples with a plurality of said relational data stream processing programs together functioning as a relational stream processing system so as to execute at least one relational stream processing query including at least one relational stream processing operation against at least one input stream received from at least one external tuple data producer/publisher to produce at least one output tuple data stream sent to at least one external tuple data consumer/subscriber;
(c) receiving input streams of tuples by said relational data stream processing programs over said data communication interfaces from at least one of:
an external tuple data producer/publisher, and an output of another relational data stream processing program which is an internal tuple data producer/publisher program;
(d) sending output streams of tuples by said relational data stream processing programs over said data communication interfaces to at least one of:
an external tuple data consumer/producer, and an input of another relational data stream processing program which is an internal tuple data consumer/producer program;
and wherein said input streams are left unaltered after processing by said relational stream processing programs;
and
(e) interoperating said internal tuple data producer/publisher programs with said internal tuple data consumer/producer programs in accordance with said current configuration in order to perform said sending and receiving;
wherein 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.

7 more elements

A memory carrying one or more sequences of instructions for performing relational processing of streams of tuples using at least one relational stream processing program executing on at least one data processing device and communicating with one another through data communication interfaces to form a network of relational stream processing programs, wherein execution of the one or more sequences of instructions by one or more processors causes the one or more processors to perform a process comprising:

holding and maintaining information to record a configuration history, including at least a current configuration, of said relational stream processing programs including currently executing relational stream processing operations of said relational stream processing programs and currently existing relational stream processing queries;
processing said streams of tuples with a plurality of said relational stream processing programs together functioning as a relational stream processing system so as to execute at least one relational stream processing query including at least one relational stream processing operation against at least one input stream received from at least one external tuple data producer/publisher to produce at least one output stream sent to at least one external tuple data consumer/subscriber;
receiving input streams of tuples by said data stream processing programs over said data communication interfaces from at least one of:
an external tuple data producer/publisher, and an output of another relational stream processing program which is an internal tuple data producer/publisher program;
sending output streams of tuples by said relational stream processing programs over said data communication interfaces to at least one of:
an external tuple data consumer/producer, and an input of another relational stream processing program which is an internal tuple data consumer/producer program;
and wherein said input streams are left unaltered after processing by said relational stream processing programs;
and
interoperating said internal tuple data producer/publisher programs with said internal tuple data consumer/producer programs in accordance with said current configuration in order to perform said sending and receiving;
wherein said relational stream processing operations process said input streams so as to perform said relational stream processing operations over said tu les received in said input streams, subsequent to establishing said relational stream processing operations.

7 more elements

Dependencies are inferred from the claim text.

Facts

Application: 11/313,053Filed 20 Dec 2005 · continuation
Priority: 15 Mar 2003
Granted: 20 Jan 2009
Term ends: Not estimatedThe source records don’t support an estimate.

Classification14 codes

H04L 67/10
Protocols: in which an application is distributed across nodes in the network
G06F 16/24568
Query execution: data stream processing; Continuous queries
H04L 67/02
Protocols: based on web technology, e.g. hypertext transfer protocol [HTTP]
G06F 16/83
Of semi-structured data, e.g. markup language structured data such as SGML, XML or HTML: querying