Patent ID: 9531648
Filing Date: 2016-12-27
CPC Classification: G06F,H04L

Claim Text:
1. A computer-implemented method for managing a stream of tuples, comprising: receiving the stream of tuples to be processed by a plurality of stream operators operating on a set of one or more computer processors; monitoring a stream operator for a triggering condition; creating, responsive to a presence of the triggering condition, an overflow path that includes at least one stream operator that performs processing duplicative to at least one stream operator from the plurality of stream operators; identifying a tuple from the stream of tuples to process on the overflow path by selecting the tuple for the overflow path based on the presence of a complex attribute of the tuple that is determined through a complexity score, the complexity score is determined by a numerical weighing for a tuple so that a stream operator can identify a predicted processing time; processing an identified tuple from the stream of tuples in response to the presence of the overflow path; monitoring at least one stream operator on the overflow path for a high traffic limit and a low traffic limit, wherein the high traffic limit comprises a processing rate at a respective stream operator that is at least 10% greater than a maximum allowable processing rate, and wherein the low traffic limit comprises a processing rate at a respective stream operator that is more than 2% below a minimum allowable processing rate; creating an additional overflow path responsive to detecting the high traffic limit; and deactivating, responsive to detecting the low traffic limit, a respective overflow path that triggers the low traffic limit.