公开(公告)号：US10719533B2

公开(公告)日：2020-07-21

申请号：US15861470

申请日：2018-01-03

Applicant: salesforce.com, inc.

Inventor： Benjamin Busjaeger ,  Scott Hansma ,  Pallav Kothari ,  Michael Sgroi

IPC: G06F16/27 ,  G06F16/22

Abstract: A system may store data in a shared table of a distributed database based on generating a tenant-specific partition key. The system may receive a message from a first tenant that indicates certain data to be written to or retrieved from a shared table (e.g., shared between multiple tenants). The system may then identify a data key, a tenant identifier, and a data type identifier associated with the data and generate a partition key that includes the data key, tenant identifier, and data type identifier. The system may then transmit the partition key to the shared table, and data may be written to or retrieved from the table based on the tenant-specific partition key.

公开(公告)号：US20190205459A1

公开(公告)日：2019-07-04

申请号：US15861470

申请日：2018-01-03

Applicant: salesforce.com, inc.

Inventor： Benjamin Busjaeger ,  Scott Hansma ,  Pallav Kothari ,  Michael Sgroi

IPC: G06F17/30

Abstract: A system may store data in a shared table of a distributed database based on generating a tenant-specific partition key. The system may receive a message from a first tenant that indicates certain data to be written to or retrieved from a shared table (e.g., shared between multiple tenants). The system may then identify a data key, a tenant identifier, and a data type identifier associated with the data and generate a partition key that includes the data key, tenant identifier, and data type identifier. The system may then transmit the partition key to the shared table, and data may be written to or retrieved from the table based on the tenant-specific partition key.

公开(公告)号：US11526539B2

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

申请号：US16264367

申请日：2019-01-31

Applicant: salesforce.com, inc.

Inventor： Benjamin Busjaeger ,  Michael Sgroi ,  Jeremy Horwitz

IPC: G06F16/31 ,  G06F16/16

Abstract: Systems, methods, and computer-readable media for temporary reservation schemes, are provided. In embodiments, temporary reservations are inserted into non-relational datastore, and update records indicating changes to the non-relational datastore are streamed to processing nodes. The processing nodes store the update records in local expiration windows. The expiration windows are periodically polled for expired temporary reservations, which are then removed from the non-relational datastore. Other embodiments may be described and/or claimed.

公开(公告)号：US11126625B2

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

申请号：US16428562

申请日：2019-05-31

Applicant: salesforce.com, inc.

Inventor： Benjamin Busjaeger ,  Michael Sgroi

IPC: G06F16/2455 ,  G06F16/22 ,  G06F16/23

Abstract: Techniques are disclosed relating to caching techniques for processing a database change stream. A caching module of a computer system may receive change records from a change stream that includes a plurality of records indicating changes to a database table. The change stream may include change records for multiple shards and is accessible by providing one or more position indicators for one or more of the multiple shards to request one or more change records and an updated position indicator. The caching module may store, for changes to a set of one or more shards for which the caching module is configured, one or more cache entries that each include a group of change records up to a threshold group size. A change processor module of the computer system may request a portion of the change stream by providing a received position indicator. The change processor module may receive, from the caching module, one or more cached change records from a cache entry that matches the provided position indicator.

公开(公告)号：US20210099301A1

公开(公告)日：2021-04-01

申请号：US16588550

申请日：2019-09-30

Applicant: salesforce.com, inc.

Inventor： Benjamin Busjaeger ,  Koson Thambundit ,  Jeremy Horwitz ,  Michael Sgroi ,  Jeffrey M. Bergan ,  Benjamin James Fry ,  Brian Robert McNamara

IPC: H04L9/32 ,  H04L29/06 ,  G06F16/955 ,  G06F16/9035 ,  G06F16/907

Abstract: A multi-tenant computer system implements a platform for providing data protection scopes to shared infrastructure services according to a nested tenant model that permits a hierarchy having a plurality of levels. The multi-tenant computer system provisions data protection scopes for cloud products, service products, cloud product tenants, service products operating in the context of cloud products, service products operating in the context of cloud product tenants, and combinations of the foregoing.

公开(公告)号：US20230169049A1

公开(公告)日：2023-06-01

申请号：US17457244

申请日：2021-12-01

Applicant: salesforce.com, inc.

Inventor： Michael Sgroi ,  Helen Kwong ,  Benjamin Busjaeger ,  Igor Fedorenko

IPC: G06F16/21 ,  G06F16/23 ,  G06F16/22 ,  G06F16/2455

CPC classification number: G06F16/213 ,  G06F16/2358 ,  G06F16/2282 ,  G06F16/24552

Abstract: Techniques are disclosed relating to database schemas. A computer system may receive a metadata document that describes an updated schema for a database that stores a plurality of records. The computer system may instantiate a set of processes to perform an upgrade routine to upgrade ones of the plurality of records to comply with the updated schema. While the set of processes are upgrading the records, the computer system may receive a request to perform an operation on one of the plurality of records. The computer system may detect that the record corresponds to an earlier schema version than a version of the updated schema of the metadata document and may upgrade the record to comply with that updated schema. After upgrading the record, the computer system may perform the requested operation on the record.

公开(公告)号：US20210390105A1

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

申请号：US17446197

申请日：2021-08-27

Applicant: salesforce.com, inc.

Inventor： Benjamin Busjaeger ,  Michael Sgroi

IPC: G06F16/2455 ,  G06F16/22 ,  G06F16/23

Abstract: Techniques are disclosed relating to caching techniques for processing a database change stream. A computer system may receive change records from a change stream that includes a plurality of records indicating changes to a database table. The change stream may include change records for multiple shards and be accessible by providing one or more position indicators for one or more of the multiple shards to request one or more change records and an updated position indicator. The system may store, for changes to a set of one or more shards, one or more cache entries that include respective groups of change records. The system may request a portion of the change stream by providing a received position indicator. The system may provide one or more cached change records from a cache entry that matches the provided position indicator.

公开(公告)号：US11940963B2

公开(公告)日：2024-03-26

申请号：US17457244

申请日：2021-12-01

Applicant: salesforce.com, inc.

Inventor： Michael Sgroi ,  Helen Kwong ,  Benjamin Busjaeger ,  Igor Fedorenko

IPC: G06F16/21 ,  G06F16/22 ,  G06F16/23 ,  G06F16/2455

CPC classification number: G06F16/213 ,  G06F16/2282 ,  G06F16/2358 ,  G06F16/24552

Abstract: Techniques are disclosed relating to database schemas. A computer system may receive a metadata document that describes an updated schema for a database that stores a plurality of records. The computer system may instantiate a set of processes to perform an upgrade routine to upgrade ones of the plurality of records to comply with the updated schema. While the set of processes are upgrading the records, the computer system may receive a request to perform an operation on one of the plurality of records. The computer system may detect that the record corresponds to an earlier schema version than a version of the updated schema of the metadata document and may upgrade the record to comply with that updated schema. After upgrading the record, the computer system may perform the requested operation on the record.

公开(公告)号：US11650985B2

公开(公告)日：2023-05-16

申请号：US17446197

申请日：2021-08-27

Applicant: salesforce.com, inc.

Inventor： Benjamin Busjaeger ,  Michael Sgroi

IPC: G06F16/2455 ,  G06F16/22 ,  G06F16/23

CPC classification number: G06F16/24552 ,  G06F16/2282 ,  G06F16/2358 ,  G06F16/24568

Abstract: Techniques are disclosed relating to caching techniques for processing a database change stream. A computer system may receive change records from a change stream that includes a plurality of records indicating changes to a database table. The change stream may include change records for multiple shards and be accessible by providing one or more position indicators for one or more of the multiple shards to request one or more change records and an updated position indicator. The system may store, for changes to a set of one or more shards, one or more cache entries that include respective groups of change records. The system may request a portion of the change stream by providing a received position indicator. The system may provide one or more cached change records from a cache entry that matches the provided position indicator.

公开(公告)号：US11157466B2

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

申请号：US16121598

申请日：2018-09-04

Applicant: salesforce.com, inc.

Inventor： Benjamin Busjaeger ,  Michael Sgroi ,  Scott D. Hansma

IPC: G06F16/21 ,  G06F16/25 ,  G06F16/242 ,  H04L29/08

Abstract: In various embodiments, a computer system implements a service that stores a plurality of database templates that define data types supported for a non-relational database accessible to a plurality of applications. The service receives, from a developer of an application, a selection of one of the plurality of database templates to be used by the application. In response to the selection, the service issues a set of data definition language (DDL) instructions to provision the non-relational database with a schema that implements a particular data type defined by the selected template. Requests from the application to manipulate a value of the particular data type stored in the non-relational database system are serviced. In some embodiments, the servicing includes identifying a set of data manipulation language (DML) instructions to be executed and issuing the set of DML, instructions to the non-relational database.