Patent ID: 9389911
Filing Date: 2016-07-12
CPC Classification: G06F

Claim Text:
1. A method of processing data in a stream application, comprising: receiving streaming data to be processed by a plurality of processing elements, the processing elements processing at least a portion of the received data by operation of one or more computer processors, wherein each of the processing elements comprises an executable portion of code; establishing an operator graph of the plurality of processing elements, the operator graph defining at least one execution path through which the streaming data flows through the plurality of processing elements, and wherein each processing element in the execution path is configured to at least one of receive data from at least one upstream processing element and transmit data to at least one downstream processing element; receiving a request to add at least one processing element to the execution path of the operator graph; before adding the at least one processing element, identifying a predicted relative change of data throughput in a first processing element in the execution path, wherein the predicted relative change of data is based on (i) predicting utilization rates of computer processors in two or more downstream processing elements resulting from adding the at least one processing element to the operator graph, (ii) determining whether at least one downstream processing element is at or near a maximum utilization rate and (iii) determining whether, based on historical information containing conditions in the operator graph that caused backpressure previously, adding the at least one processing element will cause backpressure in the future; and upon determining that the relative change of data throughput satisfies a predetermined threshold, determining not to add the at least one processing element to the operator graph.