Reduction and optimization of information processing systems
First Claim
1. A method for arranging operations performable on message streams in a message processing system by a first operation sequence between two nodes in the system, the first operation sequence having a first select operation followed by a second select operation, the method comprising:
- converting the first operation sequence into a second, equivalent operation sequence comprising a single select operation.
0 Assignments
0 Petitions
Accused Products
Abstract
Techniques for arranging operations performable on information in an information processing system are provided. In a system having a plurality of information producers and a plurality of information subscribers, paths are identified over which information traverses, and within which the information is subject to select and/or transform operations. The present invention optimizes the system by reorganizing the sequence of select and transform operations so that transforms follow select operations; and by combining multiple select and transform operations into single select and transform operations, respectively. Using these optimizations, the processing resources of the system can be reorganized, and/or information flow graphs describing the system can be designed, so that the select operations are “pushed” toward the producers, and transform operations are “pushed” toward the subscribers. Efficient content-based routing systems can then be used to implement the select operations.
45 Citations
49 Claims
-
1. A method for arranging operations performable on message streams in a message processing system by a first operation sequence between two nodes in the system, the first operation sequence having a first select operation followed by a second select operation, the method comprising:
converting the first operation sequence into a second, equivalent operation sequence comprising a single select operation. - View Dependent Claims (2, 3, 4, 5, 6, 7)
-
8. A method for arranging operations performable on message streams in a message processing system by a first operation sequence between two nodes of the system, the first operation sequence having a first transform operation followed by a second transform operation, the method comprising:
converting the first operation sequence into a second, equivalent operation sequence comprising a single transform operation. - View Dependent Claims (9, 10, 11, 12, 13, 14)
-
15. A method for arranging operations performable on information in an information processing system, the information processing system having a plurality of information producers and a plurality of information subscribers, the method comprising:
-
identifying respective sequences of select and transform operations required on information between at least some information producer/subscriber pairs;
converting each respective sequence identified into an equivalent sequence, including;
pushing select operations ahead of transform operations in each said equivalent sequence, and combining any sequential select operations and any sequential transform operations in each said equivalent sequence;
wherein each said equivalent sequence comprises a single select operation followed by a single transform operation. - View Dependent Claims (16, 17, 18, 19, 20, 21, 22, 23)
-
-
24. A system for arranging operations performable on message streams in a message processing system by a first operation sequence between two nodes in the system, the first operation sequence having a first select operation followed by a second select operation, the system comprising:
means for converting the first operation sequence into a second, equivalent operation sequence comprising a single select operation. - View Dependent Claims (25, 26)
-
27. A system for arranging operations performable on message streams in a message processing system by a first operation sequence between two nodes of the system, the first operation sequence having a first transform operation followed by a second transform operation, the system comprising:
means for converting the first operation sequence into a second, equivalent operation sequence comprising a single transform operation. - View Dependent Claims (28, 29)
-
30. A system for arranging operations performable on information in an information processing system, the information processing system having a plurality of information producers and a plurality of information subscribers, the system comprising:
-
means for identifying respective sequences of select and transform operations required on information between at least some information producer/subscriber pairs;
means for converting each respective sequence identified into an equivalent sequence, including;
means for pushing select operations ahead of transform operations in each said equivalent sequence, and means for combining any sequential select operations and any sequential transform operations in each said equivalent sequence;
wherein each said equivalent sequence comprises a single select operation followed by a single transform operation. - View Dependent Claims (31, 32, 33, 34)
-
-
35. An article of manufacture comprising a computer useable medium having computer readable program code means embodied therein for arranging operations performable on message streams in a message processing system by a first operation sequence between two nodes in the system, the first operation sequence having a transform operation followed by a select operation, the article of manufacture comprising:
computer readable program code means for converting the first operation sequence into a second, equivalent operation sequence comprising a select operation followed by a transform operation. - View Dependent Claims (36, 37, 38)
-
39. An article of manufacture comprising a computer useable medium having computer readable program code means embodied therein for arranging operations performable on message streams in a message processing system by a first operation sequence between two nodes in the system, the first operation sequence having a first select operation followed by a second select operation, the article of manufacture comprising:
computer readable program code means for converting the first operation sequence into a second, equivalent operation sequence comprising a single select operation. - View Dependent Claims (40, 41)
-
42. An article of manufacture comprising a computer useable medium having computer readable program code means embodied therein for arranging operations performable on message streams in a message processing system by a first operation sequence between two nodes of the system, the first operation sequence having a first transform operation followed by a second transform operation, the article of manufacture comprising:
computer readable program code means for converting the first operation sequence into a second, equivalent operation sequence comprising a single transform operation. - View Dependent Claims (43, 44)
-
45. An article of manufacture comprising a computer useable medium having computer readable program code means embodied therein for arranging operations performable on information in an information processing system, the information processing system having a plurality of information producers and a plurality of information subscribers, the article of manufacture comprising:
-
computer readable program code means for identifying respective sequences of select and transform operations required on information between at least some information producer/subscriber pairs;
computer readable program code means for converting each respective sequence identified into an equivalent sequence, including;
computer readable program code means for pushing select operations ahead of transform operations in each said equivalent sequence, and computer readable program code means for combining any sequential select operations and any sequential transform operations in each said equivalent sequence;
wherein each said equivalent sequence comprises a single select operation followed by a single transform operation. - View Dependent Claims (46, 47, 48, 49)
-
Specification