公开(公告)号：US10740322B2

公开(公告)日：2020-08-11

申请号：US15836669

申请日：2017-12-08

Applicant: salesforce.com, inc.

Inventor： Anjani Gupta ,  William Victor Gray ,  Shaahin Mehdinezhad Rushan ,  Yogesh Patel ,  Shreedhar Sundaram ,  Mahalaxmi Sanathkumar ,  William Hackett ,  Rajkumar Pellakuru ,  Kshama Thacker

IPC: G06F16/23

Abstract: A method is described for collapsing a plurality of detected changes to data in a database into a reduced set of changes. The method includes detecting a plurality of changes to the database; determining that one or more changes in the plurality of changes are superfluous to demonstrating the current state of data in the database to an external system; determining, in response to determining that one or more changes in the plurality of changes are superfluous, a reduced set of changes that demonstrates the current state of data in the database based on the plurality of changes, wherein a number of changes in the plurality of changes is greater than a number of changes in the reduced set of changes; and determining a set of messages to generate based on the reduced set of changes, wherein the set of messages demonstrate the current state of data.

公开(公告)号：US10455264B2

公开(公告)日：2019-10-22

申请号：US15885065

申请日：2018-01-31

Applicant: salesforce.com, inc.

Inventor： Yogesh Patel ,  Mahalaxmi Sanathkumar ,  Shaahin Mehdinezhad Rushan ,  Bhaves Patel ,  Shreedhar Sundaram ,  Rajkumar Pellakuru ,  William Edward Hackett

IPC: H04N21/262 ,  H04N21/654 ,  H04L29/08

Abstract: Techniques are disclosed relating to bulk data extraction systems. In some embodiments, a streaming server system may receive a first request, from a data storage system, that is sent prior to initiation of a bulk data extraction for a first group of users. In response to the first request, the streaming server system may receive, from the data storage system, a first notification message that includes a particular event identifier for a most recent data event generated at the data storage system. The streaming server system may receive, from the data storage system, those messages associated with the bulk data extraction for the first group. Subsequent to completion of the bulk data extraction, the streaming server system may send, to the data storage system, a request to subscribe to notification messages for data events associated with the first group.

公开(公告)号：US20190238605A1

公开(公告)日：2019-08-01

申请号：US15884946

申请日：2018-01-31

Applicant: salesforce.com, inc.

Inventor： Yogesh Patel ,  Mahalaxmi Sanathkumar ,  Shaahin Mehdinezhad Rushan ,  William Victor Gray ,  Bhaves Patel ,  Shreedhar Sundaram ,  Rajkumar Pellakuru ,  William Edward Hackett ,  Avital Arora

IPC: H04L29/06 ,  G06F17/30

CPC classification number: H04L65/4069 ,  G06F16/24568 ,  H04L51/24 ,  H04L67/26

Abstract: Techniques are disclosed relating to verifying the sequence of messages sent via data streaming systems. In some embodiments, a streaming server system may receive a plurality of messages associated with events at a data storage system that is accessible to various groups of users. In some embodiments, each of the plurality of messages may include an event identifier for an associated event and a group-specific sequence number. The streaming server system may detect, based on group-specific sequence numbers included in a set of messages, that a particular message for a particular group has not been received. The streaming server system may send, to the data storage system, a request for the particular message and, in response to the request, may receive the particular message from the data storage system.

公开(公告)号：US20190163791A1

公开(公告)日：2019-05-30

申请号：US15828182

申请日：2017-11-30

Applicant: salesforce.com, inc.

Inventor： Mahalaxmi Sanathkumar ,  Yogesh Patel ,  Shaahin Mehdinezhad Rushan ,  William Victor Gray ,  William Edward Hackett ,  Shreedhar Sundaram ,  Rajkumar Pellakuru ,  Anjani Gupta ,  Chandra S. Chadalavada

IPC: G06F17/30

Abstract: Dynamic selection of data sources for streaming dynamic data is described. A data streaming service receives a dynamic selection of a data source after the data streaming service begins executing, the dynamic selection of the data source including an identifier of a host of a multi-tenant database and an identifier of a tenant of multiple tenants storing data in the multi-tenant database. The data streaming service streams dynamic data from the data source to a data destination.

公开(公告)号：US11609886B2

公开(公告)日：2023-03-21

申请号：US16779395

申请日：2020-01-31

Applicant: salesforce.com, inc.

Inventor： Yogesh Patel ,  Percy Mehta ,  Mattia Padovani ,  Shan-Cheng Ho ,  Shaahin Mehdinezhad Rushan ,  Johannes Kienzle

IPC: G06F16/21 ,  G06F16/27 ,  G06F16/215 ,  G06F9/54 ,  G06N7/00

Abstract: A method and system of data deduplication for data streams in a multi-tenant system. The method receives, at a data accuracy manager, an event from an activity tracking component, determine whether the event is recorded in a probabilistic model that tracks previously received events from the activity tracking component, where the probabilistic model can accurately identify the event has not been previously received with a possible false positive response where the event has been previously received, determines whether information for the event is stored in a metric storage, where the metric storage is a database of metrics derived from the previously received events, and discards the event in response to determining that the event is recorded in the probabilistic model and in the metric storage.

公开(公告)号：US20220345458A1

公开(公告)日：2022-10-27

申请号：US17238180

申请日：2021-04-22

Applicant: salesforce.com, inc.

Inventor： Jayanth Parayil Kumarji ,  Priyadarshini Mitra ,  Kevin Terusaki ,  Zhidong Ke ,  Yifeng Liu ,  Utsavi Benani ,  Heng Zhang ,  Evan Jiang ,  Birva Joshi ,  Yogesh Patel

IPC: H04L29/06

Abstract: Various techniques and mechanisms for sharing remote resources among a trusted group are disclosed. A credential management agent utilizes a resource credential for a first user to access a secure resource corresponding to the first user for a second user by at least validating a second user and validating a consent of the first user to allow the second user to access the secure resource using the resource credential for the first user. The secure resource resides on a remote server system accessible via one or more application program interfaces (APIs). A platform management agent provides an interface for shared resource-agnostic credential sharing. The platform management agent validates credentials for the second user as belonging to a trusted group and forwards a request for access to the secure resource for the second user to the credential management agent. In response to receiving the resource credential for the first user to access the secure resource, the platform management agent accesses the secure resource on behalf of the second user to allow the second user to utilize the secure resource.

公开(公告)号：US20210240679A1

公开(公告)日：2021-08-05

申请号：US16779395

申请日：2020-01-31

Applicant: Salesforce.Com, Inc.

Inventor： Yogesh Patel ,  Percy Mehta ,  Mattia Padovani ,  Shan-Cheng Ho ,  Shaahin Mehdinezhad Rushan ,  Johannes Kienzle

IPC: G06F16/215 ,  G06N7/00 ,  G06F9/54

Abstract: A method and system of data deduplication for data streams in a multi-tenant system. The method receives, at a data accuracy manager, an event from an activity tracking component, determine whether the event is recorded in a probabilistic model that tracks previously received events from the activity tracking component, where the probabilistic model can accurately identify the event has not been previously received with a possible false positive response where the event has been previously received, determines whether information for the event is stored in a metric storage, where the metric storage is a database of metrics derived from the previously received events, and discards the event in response to determining that the event is recorded in the probabilistic model and in the metric storage.

公开(公告)号：US20210240678A1

公开(公告)日：2021-08-05

申请号：US16779386

申请日：2020-01-31

Applicant: Salesforce.com, inc.

Inventor： Yogesh Patel ,  Percy Mehta ,  Mattia Padovani ,  Shan-Cheng Ho ,  Shaahin Mehdinezhad Rushan ,  Johannes Kienzle

IPC: G06F16/215 ,  G06F16/28 ,  G06F16/27

Abstract: A method enables data aggregation in a multi-tenant system. The method includes receiving, at a data aggregation manager, an event from an activity tracking component, generating, by the data aggregation manager, a first hash value based on a first identifier in the event, generating, by the data aggregation manager, a second hash value based on a second identifier in the event, and storing event message information to an entry of a metric storage database in a partition according the first hash value and the second hash value.

公开(公告)号：US11601495B2

公开(公告)日：2023-03-07

申请号：US16779418

申请日：2020-01-31

Applicant: salesforce.com, inc.

Inventor： Yogesh Patel ,  Percy Mehta ,  Shardul Vikram ,  Mattia Padovani

IPC: H04L67/10 ,  H04W24/10 ,  G06F16/22 ,  G06F9/48 ,  H04W4/029 ,  G06F9/50

Abstract: A method and system that perform cluster node work assignments for tenants in a multi-tenant system. The method includes selecting a partition of a cluster tenant tracking structure having a hierarchical namespace and virtual nodes representing each tenant by a cluster node foreman controller, searching the selected partition for a tenant that is unlocked in the cluster tenant tracking structure, and initiating work for the tenant by the cluster node.

公开(公告)号：US11537572B2

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

申请号：US16779386

申请日：2020-01-31

Applicant: salesforce.com, inc.

Inventor： Yogesh Patel ,  Percy Mehta ,  Mattia Padovani ,  Shan-Cheng Ho ,  Shaahin Mehdinezhad Rushan ,  Johannes Kienzle

IPC: G06F16/215 ,  G06F16/27 ,  G06F16/28

Abstract: A method enables data aggregation in a multi-tenant system. The method includes receiving, at a data aggregation manager, an event from an activity tracking component, generating, by the data aggregation manager, a first hash value based on a first identifier in the event, generating, by the data aggregation manager, a second hash value based on a second identifier in the event, and storing event message information to an entry of a metric storage database in a partition according the first hash value and the second hash value.