Method for distributed RDSMS
First Claim
Patent Images
1. A distributed data stream management system comprising:
- a network of communicating relational stream processing computer nodes distributed and configured for processing streams of data records received from at least one external source external of said system, according to relational stream processing operations, without a need to include a persistent relational database element to process said streams of data records, and outputting processed streams of data records to at least one external consumer external of said system;
at least two of said relational stream processing computer nodes each comprising;
an input interface configured to receive input streams of said streams of data records; and
an output interface configured to transmit output streams of said streams of data records;
a central configuration server operably connectable to said relational stream processing computer nodes to communicate with said relational stream processing computer nodes;
wherein said streams of data records received from at least one external source are broken up into component pieces and said component pieces are allocated to different ones of said relational stream processing computer nodes for said processing;
wherein said at least two of said relational stream processing computer nodes aggregate a plurality of said output streams into a consumer output stream of said streams of records and output said consumer output stream to at least one of said at least one external consumer;
wherein said component pieces are managed by said relational stream processing nodes, respectively, in retransmission buffers, and said relational stream processing nodes dispose of said managed component pieces upon receipt of acknowledgement from a predefined subset of said at least one external consumer that said consumer output stream has been successfully received; and
wherein said stream processing computer nodes operate in a functionally equivalent manner as if a single stream processing computer node processed said streams of data records received from at least one external source.
2 Assignments
0 Petitions
Accused Products
Abstract
Methods for processing streaming data records are provided that include facilities for defining and naming multiple input and output data streams using relational processing definitions and abstractions similar to those found in relational database management systems (RDBMS) and embodied as a set of communicating stream processing nodes. The result is a Distributed Data Stream Management System (DDSMS) which is also a kind of Relational Data Stream Management System (RDSMS). The former comprises a set of Relational Data Stream Management System (RDSMS) nodes, whereas the latter might contain only a single RDSMS node.
75 Citations
20 Claims
-
1. A distributed data stream management system comprising:
-
a network of communicating relational stream processing computer nodes distributed and configured for processing streams of data records received from at least one external source external of said system, according to relational stream processing operations, without a need to include a persistent relational database element to process said streams of data records, and outputting processed streams of data records to at least one external consumer external of said system; at least two of said relational stream processing computer nodes each comprising; an input interface configured to receive input streams of said streams of data records; and an output interface configured to transmit output streams of said streams of data records; a central configuration server operably connectable to said relational stream processing computer nodes to communicate with said relational stream processing computer nodes; wherein said streams of data records received from at least one external source are broken up into component pieces and said component pieces are allocated to different ones of said relational stream processing computer nodes for said processing; wherein said at least two of said relational stream processing computer nodes aggregate a plurality of said output streams into a consumer output stream of said streams of records and output said consumer output stream to at least one of said at least one external consumer; wherein said component pieces are managed by said relational stream processing nodes, respectively, in retransmission buffers, and said relational stream processing nodes dispose of said managed component pieces upon receipt of acknowledgement from a predefined subset of said at least one external consumer that said consumer output stream has been successfully received; and wherein said stream processing computer nodes operate in a functionally equivalent manner as if a single stream processing computer node processed said streams of data records received from at least one external source. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9)
-
-
10. A method of monitoring comprising:
-
providing a network of communicating relational stream processing computer nodes distributed and configured for processing streams of data records; receiving said streams of data records from at least one sensor; breaking up said streams of data records into component substreams and allocating said component substreams to different ones of said relational stream processing computer nodes; processing said component substreams by said different ones of said relational stream processing computer nodes according to relational stream processing operations; aggregating a plurality of output streams, outputted by said different ones of said relational stream processing computer nodes, resulting from said processing; and outputting an aggregated stream resulting from said aggregating to at least one consumer; wherein said component substreams are managed by said relational stream processing nodes, respectively, in retransmission buffers, and said relational stream processing nodes dispose of said managed component substreams upon receipt of acknowledgement from a predefined subset of said at least one consumer that said aggregated stream has been successfully received. - View Dependent Claims (11)
-
-
12. A method of processing streams of data records, said method comprising:
-
providing a network of communicating relational stream processing computer nodes distributed and configured for processing streams of data records; receiving said streams of data records from at least one source; breaking up a set of relational stream processing operations to be performed on said streams of data records into component pieces of said set and allocating said component pieces to different ones of said relational stream processing computer nodes; processing said streams of data by said different ones of said relational stream processing nodes according to said component pieces of said set of relational stream processing operations assigned to each of said different ones of said relational stream processing nodes, respectively; aggregating a plurality of output streams, outputted by said different ones of said relational stream processing computer nodes, resulting from said processing; and outputting an aggregated stream resulting from said aggregating to at least one a consumer; wherein said component pieces are managed by said relational stream processing nodes, respectively, in retransmission buffers, and said relational stream processing nodes dispose of said managed component pieces upon receipt of acknowledgement from a predefined subset of said at least one consumer that said aggregated stream has been successfully received. - View Dependent Claims (13, 14, 15, 16, 17, 18, 19, 20)
-
Specification