Streaming delay patterns in a streaming environment
AssigneeInternational Business Machines Corporation
InventorsMichael J. Branson, Bradford L. Cobb, John M. Santosuosso
Life of this patent
Estimating the term…
Abstract
The method and system receive streaming data to be processed by a plurality of processing elements comprising one or more stream operators. One embodiment is directed to a method and a system for managing processing in a streaming application. A stream operator may select a delay pattern. The stream operator may compare one or more performance factors from the delay pattern to one or more optimal performance factors. The stream operator may delay the stream of tuples using the delay pattern if the performance factors are determined by the optimal performance factors.
Claims16
A method for managing processing in a streaming application, comprising:
- receiving a stream of tuples to be processed by a plurality of processing elements operating on one or more computer processors, each processing element having one or more stream operators, each processing element assigned to one or more compute nodes;
- selecting a delay pattern on a stream operator;
- comparing one or more performance factors from the delay pattern to one or more optimal performance factors;
- and
- using the delay pattern for the stream of tuples if the performance factors are determined by the optimal performance factors.
A method for managing processing in a streaming application, comprising:
- receiving a stream of tuples to be processed by a plurality of processing elements operating on one or more computer processors, each processing element having one or more stream operators, each processing element assigned to one or more compute nodes;
- determining if the streaming application is in a constrained environment;
- predicting a performance factor for a delay pattern, wherein the prediction is determined by a presence of the constrained environment;
- selecting an optimal delay pattern, wherein the optimal delay pattern is determined by the performance factor;
- and
- delaying the processing at an aggregate stream operator using the optimal delay pattern.
16-23. (canceled)
Dependencies are inferred from the claim text.