International Business Machines Corporation

Torrent Systems, Inc.

Metra Tech

David Albert Blair

Michael James Beckerle

Shyam R Mudambi

Allen M Razdow

Steven Rosenthal

Jerry Lee Callen

Lawrence A Bookman

Robert Louis Krawitz

Robert Louise Krawitz

With a continuous source of data relating to transactions, the data may be segmented and processed in a data flow arrangement, optionally in parallel, and the data may be processed without storing the data in an intermediate database. Data from multiple sources may be processed in parallel. The segmentation also may define points at which aggregate outputs may be provided, and where checkpoints may be established.

Segmentation and processing of continuous data streams using transactional semantics

To efficiently process a parameterized query against a relational database in a streaming transaction processing system, the transaction stream is treated as a sequence of multi-record 'chunks' and a single 'quasi-batch' query is executed for each chunk. A specific table in the database holds the parameter values obtained from each transaction and the parameters are bound to the rest of the query by using a database join. Another embodiment uses a framework that automates the technique by accepting the parameterized query, identifying inputs and outputs, reading the stream for the parameter values and building the parameter table, converting the parameterized query into an equivalent query that contains a join against the parameter table, performing the equivalent query and inserting the resulting query values into the stream.

Method and apparatus for efficiently processing queries in a streaming transaction processing system

Growing community of inventors

Wayland, MA, United States of America

David Albert Blair