| 摘要 |
A method and potential embodiment for processing streaming data records is described which provides facilities for defining and naming multiple input and output data streams (along with their related transformation, filtering, aggregation and other processing operations) using relational processing definitions, abstractions and techniques similar to those found in relational database management systems (RDBMS) and which is embodied as a set of communicating stream processing nodes. Whereas RDBMS process queries on a centralized processing node against historical stored data records, DDSMS process queries on distributed processing nodes against future flowing data records. The result is a Distributed Data Stream Management System (DDSMS) comprising a set of relational stream processing nodes that work and communicate together in concert to perform useful distributed data processing for a variety of applications such as service monitoring, alerting, message brokering and other applications.
|
