Wal-mart Stores, Inc.

Taraka Subrahmanya Prasad Siripurapu

Anand Rajaraman

Wang Chee Lam

Zoheb Vacheri

Lu Liu

AnHai Doan

Digvijay Singh Lamba

Madhusudan Mathihalli

Nikesh Garera

Arvind Batra

Systems and methods are provided for processing a data stream in real time to identify connections between one or more social elements social elements and aggregating and storing the identified connections over a rolling time window. Social elements may be stored as nodes and connection between social elements may be stored as labeled connections between nodes. Other embodiments are provided.

Social genome

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.

Systems and methods for event stream processing

Systems and methods are provided for processing a data stream in real time to identify connections between one or more social elements social elements and aggregating and storing the identified connections over a rolling time window. Social elements may be stored as nodes and connection between social elements may be stored as labeled connections between nodes.

Systems and methods of processing events having an attribute and value pair

Exemplary embodiments allow performance of stream computations on real-time data streams using one or more map operations and/or one or more update operations. A map operation is a stream computation in which stream events in one or more real-time data streams are processed in a real-time manner to generate zero, one or more new stream events. An update operation is a stream computation in which stream events in one or more real-time data streams are processed in a real-time manner to create or update one or more static 'slate' data structures that are stored in a durable manner.

Growing community of inventors

Saratoga, CA, United States of America

Taraka Subrahmanya Prasad Siripurapu