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:
Jan. 25, 2022

Filed:

Feb. 29, 2016
Applicant:

Nec Laboratories Europe Gmbh, Heidelberg, DE;

Inventors:

Bin Cheng, Sandhausen, DE;

Apostolos Papageorgiou, Heidelberg, DE;

Martin Bauer, Eppelheim, DE;

Assignee:

NEC CORPORATION, Tokyo, JP;

Attorney:
Primary Examiner:
Int. Cl.
CPC ...
G06F 9/46 (2006.01); G06F 9/48 (2006.01); G06F 9/50 (2006.01);
U.S. Cl.
CPC ...
G06F 9/4881 (2013.01); G06F 9/4843 (2013.01); G06F 9/5066 (2013.01); G06F 9/5083 (2013.01);
Abstract

A method of the invention manages data stream processing tasks of an application topology in a stream processing system, the stream processing system having one or more data producers, one or more compute nodes, and one or more result consumers, includes: assigning geographic scope granularities to the data stream processing tasks of the application topology; receiving, by a task manager from a result consumer of the one or more result consumers, a subscription in order to trigger data processing for computing a result, the subscription including geographic scope related information concerning the triggered data processing]; generating, by the task manager based on the geographic scope related information of the subscription, an execution plan including task instances for performing the triggered data processing; and generating, by the task manager from the execution plan, a deployment plan for deploying the task instances of the execution plan on the compute nodes.


Find Patent Forward Citations

Loading…