The patent badge is an abbreviated version of the USPTO patent document. The patent badge does contain a link to the full patent document.

The patent badge is an abbreviated version of the USPTO patent document. The patent badge covers the following: Patent number, Date patent was issued, Date patent was filed, Title of the patent, Applicant, Inventor, Assignee, Attorney firm, Primary examiner, Assistant examiner, CPCs, and Abstract. The patent badge does contain a link to the full patent document (in Adobe Acrobat format, aka pdf). To download or print any patent click here.

Date of Patent:
Dec. 31, 2019

Filed:

May. 10, 2016
Applicant:

International Business Machines Corporation, Armonk, NY (US);

Inventors:

Alexander Cook, Rochester, MN (US);

Cory J. Kleinheksel, Ames, IA (US);

David M. Koster, Rochester, MN (US);

Peter A. Nicholls, Janetville, CA;

Jason A. Nikolai, Rochester, MN (US);

Attorneys:
Primary Examiner:
Int. Cl.
CPC ...
G06F 16/2453 (2019.01); H04L 29/06 (2006.01); G06F 16/901 (2019.01); G06F 9/50 (2006.01); G06F 8/41 (2018.01);
U.S. Cl.
CPC ...
H04L 65/4069 (2013.01); G06F 8/456 (2013.01); G06F 9/5066 (2013.01); G06F 16/24532 (2019.01); G06F 16/24537 (2019.01); G06F 16/9024 (2019.01); H04L 65/80 (2013.01);
Abstract

Methods and apparatus, including computer program products, implementing and using techniques for data stream processing in a runtime data processing environment. A stream processing graph that includes several connected operators is received. Source code of the operators is analyzed to identify hints describing whether an operator contains data structures, method parameters or other data that can be applied in a parallelization data processing environment. Performance metrics of the data processing environment within parallel regions is evaluated to determine whether data processing resources can be dynamically scaled up or down. In response to determining that the data processing resources can be dynamically scaled up, one or more operators are split to be processed on two or more parallel processing resources. In response to determining that the data processing resources can be dynamically scaled down, one or more operators are combined to be processed on a single parallel processing resource.


Find Patent Forward Citations

Loading…