公开(公告)号：US11520796B2

公开(公告)日：2022-12-06

申请号：US16848833

申请日：2020-04-14

Applicant: Google LLC

Inventor： Pavan Edara ,  Jonathan Forbes ,  Yang Yi

IPC: G06F16/22 ,  G06F16/2457 ,  G06F16/2458 ,  G06F16/23 ,  G06F16/248

Abstract: A method for managing data processing includes receiving, from a user of a data query system, a data query for data stored in a data store in communication with the data query system. The method also includes receiving a staleness parameter indicating an upper time boundary for the data query. The upper time boundary limits a query response to data within the data store that is older than the upper time boundary. The method further includes determining whether the data stored within the data store satisfies the staleness parameter. When a portion of the data within the data store fails to satisfy the staleness parameter, the method includes generating the query response that excludes the portion of the data that fails to satisfy the staleness parameter.

公开(公告)号：US20210382892A1

公开(公告)日：2021-12-09

申请号：US17445422

申请日：2021-08-19

Applicant: Google LLC

Inventor： Pavan Edara ,  Yang Yi

IPC: G06F16/2458 ,  G06F16/2455

Abstract: A method for managing metadata for a transactional storage system include receiving a query request at a snapshot timestamp. The query request requests return of at least one data block from a plurality of data blocks. Each data block includes a corresponding write epoch timestamp and a corresponding conversion indicator indicating whether the data block is active or has been converted at a respective conversion timestamp. The method also includes setting a read epoch timestamp equal to the earliest one of the write epoch and determining whether any of the respective conversion timestamps occurring at or before the snapshot timestamp occur after the read epoch timestamp. The method also includes determining the at least one data block requested by the query request by scanning each of the data blocks including corresponding write epoch timestamps occurring at or after the read epoch timestamp.

公开(公告)号：US20210319031A1

公开(公告)日：2021-10-14

申请号：US16848833

申请日：2020-04-14

Applicant: Google LLC

Inventor： Pavan Edara ,  Jonathan Forbes ,  Yang Yi

IPC: G06F16/2457 ,  G06F16/22 ,  G06F16/2458 ,  G06F16/248 ,  G06F16/23

Abstract: A method for managing data processing includes receiving, from a user of a data query system, a data query for data stored in a data store in communication with the data query system. The method also includes receiving a staleness parameter indicating an upper time boundary for the data query. The upper time boundary limits a query response to data within the data store that is older than the upper time boundary. The method further includes determining whether the data stored within the data store satisfies the staleness parameter. When a portion of the data within the data store fails to satisfy the staleness parameter, the method includes generating the query response that excludes the portion of the data that fails to satisfy the staleness parameter.

公开(公告)号：US11113296B1

公开(公告)日：2021-09-07

申请号：US16848780

申请日：2020-04-14

Applicant: Google LLC

Inventor： Pavan Edara ,  Yang Yi

IPC: G06F16/24 ,  G06F16/2458 ,  G06F16/2455

Abstract: A method for managing metadata for a transactional storage system include receiving a query request at a snapshot timestamp. The query request requests return of at least one data block from a plurality of data blocks. Each data block includes a corresponding write epoch timestamp and a corresponding conversion indicator indicating whether the data block is active or has been converted at a respective conversion timestamp. The method also includes setting a read epoch timestamp equal to the earliest one of the write epoch and determining whether any of the respective conversion timestamps occurring at or before the snapshot timestamp occur after the read epoch timestamp. The method also includes determining the at least one data block requested by the query request by scanning each of the data blocks including corresponding write epoch timestamps occurring at or after the read epoch timestamp.