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. 16, 2017

Filed:

Mar. 11, 2014
Applicant:

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

Inventors:

Chetan Narsude, Sunnyvale, CA (US);

Chandni Singh, Foster City, CA (US);

Thomas Weise, Mountain View, CA (US);

Pramod Immaneni, San Jose, CA (US);

David Yan, Campbell, CA (US);

Gaurav Gupta, San Jose, CA (US);

Amol Kekre, Fremont, CA (US);

Assignee:

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

Attorney:
Primary Examiner:
Int. Cl.
CPC ...
G06F 15/16 (2006.01); H04L 29/08 (2006.01); H04L 29/06 (2006.01); G06F 12/00 (2006.01);
U.S. Cl.
CPC ...
H04L 67/10 (2013.01); H04L 29/06027 (2013.01);
Abstract

Software for a distributed streaming platform receives an application. The application is structured as a directed acyclic graph (DAG) with instances of operators as nodes and streams as edges between nodes. Multiple instances of an operator access a shared database. The software receives a pre-defined hint associated with the application. The pre-defined hint sets a maximum period of time for local caching of a result from a query of the database by each of the multiple instances. The software launches the application by assigning the instances of operators to one or more containers provided by the streaming platform and initiating the streams. Each container is associated with a local cache. The software then receives a request from the application to make a dynamic adjustment that increases the maximum period of time for local caching of a result from a query of the database by each of the multiple instances.


Find Patent Forward Citations

Loading…