公开(公告)号：US09990392B2

公开(公告)日：2018-06-05

申请号：US14680675

申请日：2015-04-07

Applicant: Jeffrey Pound ,  Nathan Auch ,  Peter Bumbulis ,  Anil Goel

Inventor： Jeffrey Pound ,  Nathan Auch ,  Peter Bumbulis ,  Anil Goel

IPC: G06F17/30

CPC classification number: G06F17/30377

Abstract: Disclosed herein are system, method, and computer program product embodiments for distributed transaction processing in massively parallel processing (MPP) databases. An embodiment operates by receiving a transaction including a read timestamp corresponding to a version of data of a database associated with the query. It is determined whether a locally stored portion of the data of the database has a local timestamp that is equivalent to or after the read timestamp. A lock may be requested, and if received, the data is updated.

公开(公告)号：US09807168B2

公开(公告)日：2017-10-31

申请号：US14684132

申请日：2015-04-10

Applicant: Nathan Auch ,  Peter Bumbulis ,  Anil Goel ,  Jeffrey Pound

Inventor： Nathan Auch ,  Peter Bumbulis ,  Anil Goel ,  Jeffrey Pound

IPC: G06F15/16 ,  H04L29/08 ,  G06F15/167

CPC classification number: H04L67/1097 ,  G06F15/167

Abstract: Disclosed herein are system, method, and computer program product embodiments for accessing a distributed shared log that supports a total order over log writes and multiple logical log streams. An embodiment operates by selecting a range of log entries for a logical log stream from the distributed shared log and mapping the selected range of log entries to associated storage units in a plurality of storage units. The selected range of log entries are stored at the associated storage units according to metadata that indexes the selected range of log entries by logical log stream. The selected range of log entries are then requested from the associated storage units based on the mapping. The selected range of log entries for the logical log stream are then returned from the associated storage units based on a scan of the metadata. The received log entries are then reassembled.

公开(公告)号：US20160301753A1

公开(公告)日：2016-10-13

申请号：US14684132

申请日：2015-04-10

Applicant: Nathan Auch ,  Peter Bumbulis ,  Anil Goel ,  Jeffrey Pound

Inventor： Nathan Auch ,  Peter Bumbulis ,  Anil Goel ,  Jeffrey Pound

IPC: H04L29/08 ,  G06F15/167

CPC classification number: H04L67/1097 ,  G06F15/167

Abstract: Disclosed herein are system, method, and computer program product embodiments for accessing a distributed shared log that supports a total order over log writes and multiple logical log streams. An embodiment operates by selecting a range of log entries for a logical log stream from the distributed shared log and mapping the selected range of log entries to associated storage units in a plurality of storage units. The selected range of log entries are stored at the associated storage units according to metadata that indexes the selected range of log entries by logical log stream. The selected range of log entries are then requested from the associated storage units based on the mapping. The selected range of log entries for the logical log stream are then returned from the associated storage units based on a scan of the metadata. The received log entries are then reassembled.

Abstract translation: 这里公开了用于访问分布式共享日志的系统，方法和计算机程序产品实施例，其支持在日志写入和多个逻辑日志流上的总顺序。 实施例通过从分布式共享日志中选择用于逻辑日志流的日志条目的范围来操作，并将所选择的日志条目范围映射到多个存储单元中的相关联的存储单元。 所选择的日志条目的范围根据通过逻辑日志流对所选择的日志条目范围进行索引的元数据存储在相关联的存储单元处。 然后基于映射从相关联的存储单元请求所选择的日志条目的范围。 然后，基于元数据的扫描，从相关联的存储单元返回逻辑日志流的所选择的日志条目范围。 接收的日志条目然后重新组合。

公开(公告)号：US20160299932A1

公开(公告)日：2016-10-13

申请号：US14680675

申请日：2015-04-07

Applicant: JEFFREY POUND ,  Nathan Auch ,  Peter Bumbulis ,  Anil Goel

Inventor： JEFFREY POUND ,  Nathan Auch ,  Peter Bumbulis ,  Anil Goel

IPC: G06F17/30

CPC classification number: G06F17/30377

Abstract: Disclosed herein are system, method, and computer program product embodiments for distributed transaction processing in massively parallel processing (MPP) databases. An embodiment operates by receiving a transaction including a read timestamp corresponding to a version of data of a database associated with the query. It is determined whether a locally stored portion of the data of the database has a local timestamp that is equivalent to or after the read timestamp. A lock may be requested, and if received, the data is updated.

Abstract translation: 本文公开了用于大规模并行处理（MPP）数据库中的分布式事务处理的系统，方法和计算机程序产品实施例。 实施例通过接收包括对应于与查询相关联的数据库的数据的版本的读取时间戳的事务来操作。 确定数据库的数据的本地存储部分是否具有等同于或读取时间戳之后的本地时间戳。 可能会要求锁定，如果收到，则更新数据。