公开(公告)号：US20220245170A1

公开(公告)日：2022-08-04

申请号：US17248574

申请日：2021-01-29

Applicant: salesforce.com, inc.

Inventor： Yogesh Patel ,  Birva Joshi ,  Shan-Cheng Ho ,  Mahalaxmi Sanathkumar ,  Priya Sethuraman

IPC: G06F16/27 ,  G06F16/23 ,  G06Q10/10

Abstract: A method of syncing data across multiple systems includes: receiving a plurality of calendar events from a plurality of independent calendar systems that use different calendar system specific schemas; aggregating the calendar events at a unifying communication system; converting the calendar events from a calendar system specific schema to a unifying communication system specific schema; storing the plurality of calendar events in the unifying communication system specific schema; converting a calendar event received from a non-master calendar system to the master calendar system specific schema; and sending the converted calendar event to the master calendar system; wherein copies of the received calendar events that are formatted according to the calendar system specific schema of the master calendar system are stored with the master calendar system, and copies of the calendar events that are formatted according to the unifying communication system specific schema are stored with the unifying communication system.

公开(公告)号：US20210240714A1

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

申请号：US16779398

申请日：2020-01-31

Applicant: salesforce.com, inc.

Inventor： Shan-Cheng Ho ,  Percy Mehta ,  Yogesh Patel ,  Lucas Ung ,  Birva Joshi ,  Wing Hing Ku ,  Mattia Padovani

IPC: G06F16/2455 ,  G06F16/27

Abstract: A method and system manage synchronization of data streams in a multi-tenant system. The method includes tracking by a flow control mechanism a recent flow rate of at least one data stream, determining by the flow control mechanism whether the flow rate of the at least one data stream varies from at least one related data stream, and adjusting by the flow control mechanism a throughput of the at least one data stream to correlate with the at least one related data stream, in response to determining that the at least one data stream has varied from the at least one related data stream.

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