Wal-mart Stores, Inc.

Kosmix Corporation

Wang Chee Lam

Anand Rajaraman

Taraka Subrahmanya Prasad Siripurapu

Zoheb Vacheri

Lu Liu

AnHai Doan

Digvijay Singh Lamba

Michel A Tourn

Venky Harinarayan

Gaurav Bhalotia

Seshadri Srinivasan

Subramanyam Mallela

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 of processing events having an attribute and value pair

Determining one or more concepts associated with a query is disclosed. A query is received. A list of concepts and associated scores is received. The concepts fit within a concept hierarchy. A density function is used to evaluate the received concepts. One or more concepts are associated with the query based at least in part on the results of the density function.

Determining concepts associated with a query

Delivering a search result is disclosed. A category is associated with a document based at least in part on one or more scores that measure the relevance of that document to a base category. A search query is obtained. One or more results is delivered in a manner that includes an indication of at least one category with which the result is associated.

Delivering search results

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.

Processing data feeds

Delivering search results is disclosed. A search term is obtained and categories are determined. Results specific to each category are obtained and ranked based on a criterion that is specific to each category. The results are ranked based at least in part on a topic dependent score and may also be ranked in part on a topic independent score.

Growing community of inventors

San Jose, CA, United States of America

Wang Chee Lam