×

Method for predicting performance of distributed stream processing systems

  • US 8,499,069 B2
  • Filed: 04/02/2008
  • Issued: 07/30/2013
  • Est. Priority Date: 01/10/2006
  • Status: Expired due to Fees
First Claim
Patent Images

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, where a movement of one of said input message streams to one of said output message streams comprises a data flow passing through at least one of said plurality of brokers, where in the first assignment each transform is assigned to a broker, and where the network comprises both links providing logical connections for data flows between entities in the network and channels providing physical media over which the data flows corresponding to the logical connections travel, the channels physically connecting the brokers, where one or more links are assigned to each channel in the first assignment;

    performing optimization upon said first assignment of said plurality of transforms using said estimated performance to produce a second assignment, wherein performing optimization further comprises;

    re-estimating the performance of said system based at least on computation of a flow service time Wf for each of said plurality of data flows and computation of a utilization for each of said plurality of brokers, each of said plurality of links, and each of said pluralities of channels;

    identifying a most loaded channel having a highest one of said utilizations of said plurality of channels;

    reassigning at least one transform from a highest utilized broker to brokers within a predetermined number of channels away from the highest utilized broker;

    performing re-estimating and reassigning at least one transform for each of the brokers within the predetermined number of channels away from the highest utilized broker;

    selecting a best reassignment from the reassigning at least one transform and as judged by the re-estimating as the second assignment; and

    reassigning said plurality of transforms in accordance with said second assignment; and

    where the reassigning said plurality of transforms results in at least one transform being reassigned from an initial broker to a different broker.

View all claims
  • 0 Assignments
Timeline View
Assignment View
    ×
    ×