公开(公告)号：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.

公开(公告)号：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.

公开(公告)号：US20230101004A1

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

申请号：US17491105

申请日：2021-09-30

Applicant: salesforce.com, inc.

Inventor： Yogesh Prabhudas Patel ,  Syed Mohammad Raza Hussain ,  Rajkumar Pellakuru ,  Johannes Kienzle ,  Violet Gong

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

Abstract: An indication to migrate requested data objects stored in a source database environment to a destination database environment is received. Some of data objects have many-to-one relationships with other data objects in the source database environment. At least one snapshot file generated by the source database environment is transferred to a destination database environment in bulk transfer mode. Subsequent incoming data received during bulk transfer mode, after the indication is stored in a temporary table. Upon completion of migration of the requested data objects the system transitions from bulk transfer mode to streaming mode. The subsequent incoming data from the temporary table is transferred to the destination database environment in response to the transition to streaming mode. Additional data received after the temporary table is empty is transferred from the source database environment to the destination database environment without use of the temporary table.

公开(公告)号：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.