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

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

公开(公告)号：US10904303B2

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

申请号：US15994126

申请日：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: H04L29/06 ,  H04L29/08 ,  G06F9/455 ,  G06F3/06

Abstract: A cloud computing service is used to deploy a virtual computer cluster. The virtual computer cluster is initialized with a set of one or more streaming nodes for processing first messages of one or more streaming jobs. It is determined whether the virtual computer cluster is to process second messages of a non-streaming job. In response to determining that the virtual computer cluster is to process the second messages of the non-streaming job, for example using control messages, the cloud computing service is caused to start a non-streaming node in the virtual computer cluster. The non-streaming node is tasked to process the second messages of the non-streaming job.

公开(公告)号：US10671975B2

公开(公告)日：2020-06-02

申请号：US15866929

申请日：2018-01-10

Applicant: salesforce.com, inc.

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

IPC: G06F16/2455 ,  G06Q10/10 ,  H04L29/06

Abstract: In accordance with embodiments, there are provided mechanisms and methods for facilitating smart streaming of data between external systems and service providers in an on-demand services environment according to one embodiment. In one embodiment and by way of example, a method comprises splitting, by a streaming server computing device (“streaming device”), a file including messages associated with multiple tenants in a multitenant environment based on growth of the file over a time-period. The method may further include grouping, by the streaming device, the messages into multiple files based on intelligence fields associated with one or more of the messages and the tenants, where each file of the multiple files corresponds to a tenant of the multiple tenants. The method may further include uploading, by the streaming device, the multiple files to a database device associated with a service provider and coupled to the streaming server device.

公开(公告)号：US20190238918A1

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

申请号：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 ,  H04L29/08 ,  H04N21/654

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.

公开(公告)号：US11157859B2

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

申请号：US14332558

申请日：2014-07-16

Applicant: salesforce.com, inc.

Inventor： Nima Motamedi ,  Ashwini Govindaraman ,  Gregory Lapouchnian ,  James Fai-Kuen Tam ,  Shaahin Mehdinezhad Rushan ,  Tam Duc Tran ,  Alireza Bakhtiari Koohsorkhi

IPC: G06Q10/06 ,  G06F40/134

Abstract: Some embodiments of the present invention include a method for creating, via a first user interface, at least one link in a performance summary to link to supporting information of an employee's work associated with the performance summary. The performance summary including the at least one link is then displayed via the first user interface. The method then detects, via the first user interface, when the at least one link in the performance summary is selected. Responsive to the at least one link being selected, the supporting information of the employee's work associated with the performance summary is displayed via the first user interface.

公开(公告)号：US11138204B2

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

申请号：US16530680

申请日：2019-08-02

Applicant: salesforce.com, inc.

Inventor： Percy Dara Mehta ,  Yogesh Prabhudas Patel ,  Shaahin Mehdinezhad Rushan ,  Mattia Padovani ,  Aaron Yulong Zhang ,  Shan-Cheng Ho ,  Clinton Tran ,  Birva Pankaj Joshi ,  Mugdha Choudhari ,  Johannes Kienzle

IPC: G06F16/30 ,  G06F16/2455 ,  G06F16/28

Abstract: Techniques are disclosed for generating metrics for a stream of interaction data. In some embodiments, a computing system receives a stream of interaction data that is based on user interactions with one or more computing systems, where the stream of interaction data includes information for multiple interaction characteristics including an interaction category. In response to receiving additional interaction information in the stream of interaction data, the computing system may generate cumulative metric values for one or more interaction categories. Generating cumulative metric values may include: sharding the additional interaction information based on multiple characteristics including interaction category, storing the sharded information in a non-relational database, determining respective metric values for shards modified by the storing, storing the respective metric values and shard information for each of the modified shards in a relational database, querying the relational database using one or more interaction categories corresponding to the modified shards, and determining the cumulative metric values based on the results of the querying.

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

公开(公告)号：US20210034627A1

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

申请号：US16530680

申请日：2019-08-02

Applicant: salesforce.com, inc.

Inventor： Percy Dara Mehta ,  Yogesh Prabhudas Patel ,  Shaahin Mehdinezhad Rushan ,  Mattia Padovani ,  Aaron Yulong Zhang ,  Shan-Cheng Ho ,  Clinton Tran ,  Birva Pankaj Joshi ,  Mugdha Choudhari ,  Johannes Kienzle

IPC: G06F16/2455 ,  G06F16/28

Abstract: Techniques are disclosed for generating metrics for a stream of interaction data. In some embodiments, a computing system receives a stream of interaction data that is based on user interactions with one or more computing systems, where the stream of interaction data includes information for multiple interaction characteristics including an interaction category. In response to receiving additional interaction information in the stream of interaction data, the computing system may generate cumulative metric values for one or more interaction categories. Generating cumulative metric values may include: sharding the additional interaction information based on multiple characteristics including interaction category, storing the sharded information in a non-relational database, determining respective metric values for shards modified by the storing, storing the respective metric values and shard information for each of the modified shards in a relational database, querying the relational database using one or more interaction categories corresponding to the modified shards, and determining the cumulative metric values based on the results of the querying.

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