Ebay, Incorporated

Aidan Rogers

Jennica Pounds

Stanislav Pugach

Kang Chung Liu

Shuang Xu

Aiswarya Sridharan

Improved access of a multidimensional database can be implemented using a space-filling curve, such as a z-order curve, and a tree structure. A state engine is configured to track the state of the dimensions of the database as the tree structure is traversed. Different states allow optimizations such as avoidance of analyzing a dimension for further nodes of the tree and removal of multiple nodes in a sub-tree.

Database access using a z-curve

Aspects of the present disclosure include a system comprising a machine-readable storage medium storing instructions and computer-implemented methods for consistency mitigation in real-time streams. Consistent with some embodiments, the method includes reading a message object from a message queue and adding the message object to an aggregating cache. The aggregating cache includes a linked list of ordered message objects. The method further includes applying an aggregating function to the message objects in the linked list and persisting the aggregated message objects to a database. The method further includes clearing the message objects from the aggregating cache based on the message objects being persisted to the database.

Consistency mitigation techniques for real-time streams

Disclosed are systems, methods, and non-transitory computer-readable media for an availability oriented durability technique for distributed server systems. A server that is an entry point for a message processing stream receives a message from a client device, and in response, generating a unique identifier for the message, and adds an entry in a transaction log that including the message and the unique identifier for the message. The server appends the unique identifier to the message, and transmits the message to a second server positioned downstream from the server in the message processing stream. If the server determines that the message has not been processed through the message processing stream, the server accesses the message from the transaction log, appends the unique identifier to the first message, and re-transmitting the message to the second server positioned downstream from the server in the message processing stream.

Growing community of inventors

Shoreline, WA, United States of America

Aidan Rogers