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. 29, 2015

Filed:

Jul. 19, 2012
Applicants:

Wang Chee Lam, San Jose, CA (US);

LU Liu, Princeton, NJ (US);

Taraka Subrahmanya Prasad Siripurapu, Saratoga, CA (US);

Anand Rajaraman, Palo Alto, CA (US);

Zoheb Vacheri, Sunnyvale, CA (US);

Anhai Doan, Madison, WI (US);

Inventors:

Wang Chee Lam, San Jose, CA (US);

Lu Liu, Princeton, NJ (US);

Taraka Subrahmanya Prasad Siripurapu, Saratoga, CA (US);

Anand Rajaraman, Palo Alto, CA (US);

Zoheb Vacheri, Sunnyvale, CA (US);

AnHai Doan, Madison, WI (US);

Assignee:

Wal-Mart Stores, Inc., Bentonville, AR (US);

Attorney:
Primary Examiner:
Int. Cl.
CPC ...
G06F 3/00 (2006.01); G06F 9/44 (2006.01); G06F 9/46 (2006.01); G06F 13/00 (2006.01); G06F 9/48 (2006.01); G06F 9/54 (2006.01);
U.S. Cl.
CPC ...
G06F 9/4843 (2013.01); G06F 9/4881 (2013.01); G06F 9/542 (2013.01);
Abstract

Disclosed are systems and methods for processing events in an event stream using a map-update application. The events may be embodied as a key-attribute pair. An event is processed by one or more instances implementing either a map or an update function. A map function receives an input event from the event stream and publishes one or more events to the event stream. An update function receives an event and updates a corresponding slate and publishes zero or more events. Systems and methods are also disclosed herein for implementing a map-update application in a multithreaded architecture and for handling overloading of a particular thread or node. Systems and methods for providing access to slates updated according to update operations are also disclosed.


Find Patent Forward Citations

Loading…