Method for Predicting Performance of Distributed Stream Processing Systems
First Claim
1. A method comprising:
- estimating a performance of a processing system using queueing theory wherein said processing system comprises a network that receives at least one input message stream, transforms said at least one input message stream into at least one output message stream utilizing a plurality of transforms distributed in a first assignment among a plurality of brokers, and outputs said at least one output message stream;
performing optimization upon said first assignment of said plurality of transforms using said estimated performance to produce a second assignment; and
reassigning said plurality of transforms in accordance with said second assignment.
0 Assignments
0 Petitions
Accused Products
Abstract
A method comprises estimating a performance of a processing system using queueing theory wherein the processing system comprises a network that accepts at least one input message stream from a plurality of publishing clients, transforms the at least one input message stream into at least one output message stream utilizing the plurality of transforms distributed in a first assignment among the plurality of brokers, and delivers the at least one output message stream to at least one of the plurality of subscribing clients, performing optimization upon the assignment of the plurality of transforms using the estimated performance to produce a second assignment, and reassigning the plurality of transforms in accordance with the second assignment.
-
Citations
29 Claims
-
1. A method comprising:
-
estimating a performance of a processing system using queueing theory wherein said processing system comprises a network that receives at least one input message stream, transforms said at least one input message stream into at least one output message stream utilizing a plurality of transforms distributed in a first assignment among a plurality of brokers, and outputs said at least one output message stream; performing optimization upon said first assignment of said plurality of transforms using said estimated performance to produce a second assignment; and reassigning said plurality of transforms in accordance with said second assignment. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10)
-
-
11. A signal bearing medium tangibly embodying a program of machine-readable instructions executable by a digital processing apparatus to perform operations to optimize an assignment of transforms, the operations comprising:
-
estimating a performance of a processing system using queueing theory, said processing system comprising; a network comprising a plurality of brokers that receives at least one input message stream, transforms said at least one input message stream into at least one output message stream utilizing a plurality of transforms distributed in a first assignment among said plurality of brokers, and outputs said at least one output message stream; performing optimization upon said assignment of said plurality of transforms using said estimated performance to produce a second assignment; and reassigning said plurality of transforms in accordance with said second assignment. - View Dependent Claims (12, 13, 14, 15, 16, 17, 18)
-
-
19. A system comprising:
-
a network comprising a plurality of brokers that accepts at least one input message stream, transforms said at least one input message stream into at least one output message stream utilizing a plurality of transforms distributed in a first assignment among said plurality of brokers, and outputs said at least one output message stream; means for estimating a performance of said processing system using queueing theory; and means for performing optimization upon said first assignment of said plurality of transforms using said estimated performance to produce a second assignment; and means for reassigning said plurality of transforms in accordance with said second assignment. - View Dependent Claims (20, 21, 22, 23)
-
-
24. A broker machine comprising:
-
at least one transform through which passes at least one data flow wherein said broker machine is coupled to at least one other broker machine comprising at least one transform, said transforms forming a first assignment of a plurality of transforms; means for estimating a performance of said broker machine using queuing theory; means for optimizing said first assignment of said plurality of transforms using said estimated performance to produce a second assignment; and means for modifying an assignment of at least one of said plurality of transforms in accordance with said second assignment. - View Dependent Claims (25)
-
-
26. A computer program product comprising a computer usable medium having computer usable program code for optimizing an assignment of a plurality of transforms amongst a plurality of brokers, said computer program product including;
-
computer usable program code for estimating a performance of a processing system using queueing theory wherein said processing system comprises a network that receives at least one input message stream, transforms said at least one input message stream into at least one output message stream utilizing a plurality of transforms distributed in a first assignment among a plurality of brokers, and outputs said at least one output message stream; computer usable program code for performing optimization upon said first assignment of said plurality of transforms using said estimated performance to produce a second assignment; and computer usable program code for reassigning said plurality of transforms in accordance with said second assignment. - View Dependent Claims (27, 28, 29)
-
Specification