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:
May. 15, 2018

Filed:

Jun. 05, 2017
Applicant:

Datatorrent, Inc., San Jose, CA (US);

Inventors:

Amol J. Kekre, Fremont, CA (US);

Phu D. Hoang, Portola Valley, CA (US);

Chetan Narsude, Sunnyvale, CA (US);

Thomas Weise, Mountain View, CA (US);

Assignee:

DataTorrent, Inc., Santa Clara, CA (US);

Attorney:
Primary Examiner:
Assistant Examiner:
Int. Cl.
CPC ...
G06F 15/16 (2006.01); H04L 29/06 (2006.01); G06F 17/30 (2006.01);
U.S. Cl.
CPC ...
H04L 65/60 (2013.01); G06F 17/30516 (2013.01); H04L 65/4084 (2013.01); H04L 65/80 (2013.01);
Abstract

Software for a distributed streaming platform receives a specification for a streaming application and converts the specification into a logical plan that includes a directed acyclic graph (DAG) with operators as nodes and streams as edges. The software translates the logical plan into a physical plan using any stream modes as specified and with one or more instances of the operators per any static partitioning. Then the software obtains a plurality of containers running on a networked cluster of servers. One slave executes in each container. The software assigns the instances to the slaves for execution according to an execution plan that depends at least in part on the physical plan and number of containers obtained. Each slave monitors throughput of the streaming windows through the instances in the container and other statistics related to service level and reports the results of the monitoring, which are used for dynamic adjustment.


Find Patent Forward Citations

Loading…