×

Dynamic stabilization for a stream processing system

  • US 8,601,178 B2
  • Filed: 07/23/2012
  • Issued: 12/03/2013
  • Est. Priority Date: 06/13/2006
  • Status: Expired due to Fees
First Claim
Patent Images

1. A method on a processing node comprising at least a current processing element for dynamically stabilizing a stream processing system, the method comprising:

  • receiving at least one computing resource allocation target;

    associating a plurality of downstream processing elements and an upstream processing element with at least one input buffer, wherein each of the downstream processing elements consumes data packets produced by the upstream processing element received on an output stream associated with the upstream processing element;

    monitoring, for each downstream processing element in the plurality of downstream processing elements, an input rate of the downstream processing element;

    identifying, based on the monitoring, a fastest input rate among each of the input rates monitored for the plurality of downstream processing elements; and

    setting an output rate of the upstream processing element to the identified fastest input rate for the plurality of downstream processing elements.

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