公开(公告)号：US20220012214A1

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

申请号：US16922986

申请日：2020-07-07

Applicant: salesforce.com, inc.

Inventor： Zhidong Ke ,  Kevin Terusaki ,  Yifeng Liu ,  Utsavi Benani ,  Heng Zhang ,  Aaron Zhang ,  Shreedhar Sundaram ,  Mahalaxmi Sanathkumar

IPC: G06F16/18 ,  G06F16/174 ,  G06F16/17 ,  G06F16/176 ,  G06F16/22 ,  G06F11/07

Abstract: Techniques and mechanisms for incremental data ingestion are disclosed. Raw data is received from multiple disparate sources to be consumed in an environment for collecting unformatted raw data. The environment has at least a delta data table and a delta notification table. A write to an entry in the delta data table is attempted. Entries to the delta data table specify at least records indicating changes to objects in the environment. A write a corresponding entry to the delta notification table is attempted in response to a successful write attempt to the delta data table. The delta notification table entry includes information about delta data table entries for a specified period. At least one data consumer is notified that the delta data table has been modified.

公开(公告)号：US20210232604A1

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

申请号：US16775306

申请日：2020-01-29

Applicant: Salesforce.com, Inc.

Inventor： Shreedhar Sundaram ,  Mahalaxmi Sanathkumar ,  Aaron Zhang ,  Parin Kenia ,  Violet Gong ,  Priya Sethuraman ,  Zhidong Ke ,  Kevin Terusak

IPC: G06F16/28 ,  G06F16/23 ,  G06F16/2453

Abstract: A request may be received to transform records in a data lake that match one or more query criteria. Data lake records that match the criteria may be retrieved. The retrieved records may include two data lake records associated with the same data lake record identifier. A transformed record may be generated based on time stamps associated with the retrieved records.

公开(公告)号：US11321139B2

公开(公告)日：2022-05-03

申请号：US15994162

申请日：2018-05-31

Applicant: salesforce.com, inc.

Inventor： Yogesh Patel ,  William Victor Gray ,  William Hackett ,  Shaahin Mehdinezhad Rushan ,  Johannes Kienzle ,  Shreedhar Sundaram ,  Mahalaxmi Sanathkumar ,  Rajkumar Pellakuru ,  Bhaves Patel ,  Bertha Ching Wai Lam

IPC: G06F9/50 ,  G06F9/455 ,  H04L12/26 ,  H04L43/067 ,  H04L43/0876 ,  H04L43/065

Abstract: A total number of messages in a set of messages that are processed by a computing node in a virtual computer cluster during a time interval is determined. The virtual computer cluster is deployed with a cloud computing service and includes the computing node and other computing nodes at an end time of the time interval. It is determined whether the total number of messages in the set of messages processed by the computing node is no less than a maximum per-interval message number threshold. In response to determining that the total number of messages is no less than a maximum per-interval message number threshold, the cloud computing service is caused to start an additional computing node in the virtual computer cluster after the time interval, wherein the additional computing node is used to process one or more subsequent messages to be processed after the time interval.

公开(公告)号：US20210037073A1

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

申请号：US17074459

申请日：2020-10-19

Applicant: salesforce.com, inc.

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

IPC: H04L29/06 ,  H04L12/911

Abstract: Embodiments regard transfer of data streaming services to provide continuous data flow. An embodiment of an apparatus includes a processor to process data for streaming to one or more organizations; and a memory to store data for streaming to the one or more organizations, wherein the apparatus is to provide a centralized work distribution service to track status of each of a plurality of data streams to the one or more organizations, and a plurality of nodes, each node being a virtual machine to stream one or more data streams to the one or more organizations, each node including a first daemon service to monitor connectivity of the node to dependency services for the node and, upon detecting a loss of connection to one or more of the dependency services, the node to discontinue ownership of the one or more data streams of the node and a second daemon service to poll the centralized work distribution service for data streams that are not assigned.

公开(公告)号：US20190238604A1

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

申请号：US15881665

申请日：2018-01-26

Applicant: salesforce.com, inc.

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

IPC: H04L29/06

Abstract: Embodiments regard transfer of data streaming services to provide continuous data flow. An embodiment of an apparatus includes a processor to process data for streaming to one or more organizations; and a memory to store data for streaming to the one or more organizations, wherein the apparatus is to provide a centralized work distribution service to track status of each of a plurality of data streams to the one or more organizations, and a plurality of nodes, each node being a virtual machine to stream one or more data streams to the one or more organizations, each node including a first daemon service to monitor connectivity of the node to dependency services for the node and, upon detecting a loss of connection to one or more of the dependency services, the node to discontinue ownership of the one or more data streams of the node and a second daemon service to poll the centralized work distribution service for data streams that are not assigned.

公开(公告)号：US11126467B2

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

申请号：US15836670

申请日：2017-12-08

Applicant: salesforce.com, inc.

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

IPC: G06F9/50 ,  H04L12/26 ,  H04L29/08

Abstract: A method by a computing system implementing a node within a cluster of nodes to load balance among the cluster of nodes using retroactive refusal. Each of the nodes within the cluster of nodes is capable of processing work items. The method includes accepting a work item to be processed by the node, monitoring a resource utilization of the node, determining whether the resource utilization of the node exceeds a predetermined threshold, and retroactively refusing the work item in response to a determination that the resource utilization of the node exceeds the predetermined threshold, wherein the retroactive refusal causes the work item to be reassigned from the node to another node within the cluster of nodes.

公开(公告)号：US10812544B2

公开(公告)日：2020-10-20

申请号：US15881665

申请日：2018-01-26

Applicant: salesforce.com, inc.

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

IPC: H04L29/06 ,  H04L12/911

Abstract: Embodiments regard transfer of data streaming services to provide continuous data flow. An embodiment of an apparatus includes a processor to process data for streaming to one or more organizations; and a memory to store data for streaming to the one or more organizations, wherein the apparatus is to provide a centralized work distribution service to track status of each of a plurality of data streams to the one or more organizations, and a plurality of nodes, each node being a virtual machine to stream one or more data streams to the one or more organizations, each node including a first daemon service to monitor connectivity of the node to dependency services for the node and, upon detecting a loss of connection to one or more of the dependency services, the node to discontinue ownership of the one or more data streams of the node and a second daemon service to poll the centralized work distribution service for data streams that are not assigned.

公开(公告)号：US10762109B2

公开(公告)日：2020-09-01

申请号：US16047738

申请日：2018-07-27

Applicant: salesforce.com, inc.

Inventor： Shaahin Mehdinezhad Rushan ,  Percy D. Mehta ,  Yogesh Patel ,  Shan-Cheng Ho ,  Shreedhar Sundaram

IPC: G06F16/27 ,  G06F16/22 ,  G06F16/21 ,  G06F16/245 ,  G06F16/23

Abstract: Methods, systems, and devices for asynchronous deletion at a non-relational database are described. The non-relational database may store a set of data object associations. The non-relational database may receive a read request indicating a first data object identifier. Based on the first data object identifier indicated in the read request, the non-relational database may identify a second data object identifier according to a first data object association of the stored set of data object associations that is indexed in the non-relational database with the first data object identifier. The non-relational database may determine that a last data entry that is indexed in the non-relational database with the identified second data object identifier and is associated with the first data object identifier has been deleted from the non-relational database. The non-relational database may delete the first data object association from the non-relational database.

公开(公告)号：US20200034473A1

公开(公告)日：2020-01-30

申请号：US16047738

申请日：2018-07-27

Applicant: salesforce.com, inc.

Inventor： Shaahin Mehdinezhad Rushan ,  Percy D. Mehta ,  Yogesh Patel ,  Shan-Cheng Ho ,  Shreedhar Sundaram

IPC: G06F17/30

Abstract: Methods, systems, and devices for asynchronous deletion at a non-relational database are described. The non-relational database may store a set of data object associations. The non-relational database may receive a read request indicating a first data object identifier. Based on the first data object identifier indicated in the read request, the non-relational database may identify a second data object identifier according to a first data object association of the stored set of data object associations that is indexed in the non-relational database with the first data object identifier. The non-relational database may determine that a last data entry that is indexed in the non-relational database with the identified second data object identifier and is associated with the first data object identifier has been deleted from the non-relational database. The non-relational database may delete the first data object association from the non-relational database.

公开(公告)号：US10936596B2

公开(公告)日：2021-03-02

申请号：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: G06F16/2455 ,  G06F16/21 ,  G06F16/2458 ,  H04L29/08

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.