-
公开(公告)号:US11061734B2
公开(公告)日:2021-07-13
申请号:US16264399
申请日:2019-01-31
Applicant: salesforce.com, inc.
Inventor: Zhidong Ke , Kevin Terusaki , Praveen Innamuri , Narek Asadorian
IPC: G06F9/50 , G06F9/52 , G06F16/174
Abstract: Described is a system and method for compacting data into customized (e.g. optimal) file sizes for processing by computing resources. The mechanism may leverage various computing resources such as a cluster computing frameworks combined with a stream processing platform to efficiently process the activity data. For example, activity data of an organization may be processed by a set of jobs (or sub-jobs) as part of a data stream by a set of distributed computing resources. In order to efficiently process such data, the mechanism may compact the data into customized (e.g. optimal) file sizes. For example, the customized file sizes may provide an optimal (or near optimal) amount of data to be processed by each job, for example, to improve performance.
-
公开(公告)号:US20200311637A1
公开(公告)日:2020-10-01
申请号:US16366922
申请日:2019-03-27
Applicant: salesforce.com, inc.
Inventor: Utsavi Benani , Zhidong Ke , Scott W. Bishel , Praveen Innamuri , Kevin Terusaki , Shan-Cheng Ho
Abstract: Described is a method and system for verifying the end-to-end distribution of messages within an on-demand services platform. To provide the ability to monitor and trace such messages, the system may include a specialized and queryable datastore (or database) that allows the system to track the distribution and acknowledgement of messages throughout the services platform. Accordingly, a specialized verification process may be initiated to query the database to verify the receipt of a message has been acknowledged by various components within the system. In addition, the verification process may automatically retry the distribution the messages to ensure particular downstream components have received the message. Accordingly, the system alleviates the need to manual re-crawl various message source to ensure the end-to-end distribution of such messages.
-
公开(公告)号:US20190138653A1
公开(公告)日:2019-05-09
申请号:US15803412
申请日:2017-11-03
Applicant: salesforce.com, inc.
Inventor: William Christopher Fama Roller , Shardul Vikram , Alex Michael Noe , Noah William Burbank , Alexis Roos , Rohith Ramprasad , Joseph Gerald Keller , Gabriel Starr Krupa , Scott Walter Bishel , Praveen Innamuri
Abstract: Methods, systems, and devices for analyzing communication messages (e.g., emails or activities) to determine relationship strength using a distributed graph are described. In some systems, a user may be associated with a specific tenant. A database server of the system may receive communication messages associated with the user and a target user. The server may perform a natural language processing (NLP) analysis on the communication messages to extract metadata, and may generate or update a distributed graph indicating connections between users based on the extracted metadata. Using the connections of the graph, the server may calculate a closeness score between the user and the target user. Additionally, the server may calculate closeness scores between the target and other users associated with the tenant, and may determine the users with the greatest closeness scores. The server may send a suggestion for the determined users to initiate communication with the target.
-
公开(公告)号:US20180253458A1
公开(公告)日:2018-09-06
申请号:US15449500
申请日:2017-03-03
Applicant: salesforce.com, inc.
Inventor: Ankush Goyal , Shardul Vikram , Nathaniel Richard Price , Sudarshan Vijay Sarolkar , Scott Walter Bishel , Praveen Innamuri , Jon Tomas Gretarsson
CPC classification number: G06F16/23 , G06F16/245 , H04L43/103 , H04L67/1097
Abstract: A system may utilize a combination of real-time and polling connectors for data crawling. A real-time connector may use a collector to write data associated with a new event from a database to a channel and record external identifiers (IDs) associated the data. A polling connector may use a verifier to compare the recorded IDs with IDs associated with a batch of data, and may write any data of the batch of data to the channel that has not been written previously written by the collector. The system may include an onboarder for reading data previously stored in the database.
-
公开(公告)号:US11488082B2
公开(公告)日:2022-11-01
申请号:US16366922
申请日:2019-03-27
Applicant: salesforce.com, inc.
Inventor: Utsavi Benani , Zhidong Ke , Scott W. Bishel , Praveen Innamuri , Kevin Terusaki , Shan-Cheng Ho
Abstract: Described is a method and system for verifying the end-to-end distribution of messages within an on-demand services platform. To provide the ability to monitor and trace such messages, the system may include a specialized and queryable datastore (or database) that allows the system to track the distribution and acknowledgement of messages throughout the services platform. Accordingly, a specialized verification process may be initiated to query the database to verify the receipt of a message has been acknowledged by various components within the system. In addition, the verification process may automatically retry the distribution the messages to ensure particular downstream components have received the message. Accordingly, the system alleviates the need to manual re-crawl various message source to ensure the end-to-end distribution of such messages.
-
6.
公开(公告)号:US20200250007A1
公开(公告)日:2020-08-06
申请号:US16264399
申请日:2019-01-31
Applicant: salesforce.com, inc.
Inventor: Zhidong Ke , Kevin Terusaki , Praveen Innamuri , Narek Asadorian
IPC: G06F9/50 , G06F16/174 , G06F9/52
Abstract: Described is a system and method for compacting data into customized (e.g. optimal) file sizes for processing by computing resources. The mechanism may leverage various computing resources such as a cluster computing frameworks combined with a stream processing platform to efficiently process the activity data. For example, activity data of an organization may be processed by a set of jobs (or sub-jobs) as part of a data stream by a set of distributed computing resources. In order to efficiently process such data, the mechanism may compact the data into customized (e.g. optimal) file sizes. For example, the customized file sizes may provide an optimal (or near optimal) amount of data to be processed by each job, for example, to improve performance.
-
公开(公告)号:US10671589B2
公开(公告)日:2020-06-02
申请号:US15449500
申请日:2017-03-03
Applicant: salesforce.com, inc.
Inventor: Ankush Goyal , Shardul Vikram , Nathaniel Richard Price , Sudarshan Vijay Sarolkar , Scott Walter Bishel , Praveen Innamuri , Jon Tomas Gretarsson
IPC: G06F17/30 , G06F16/23 , H04L29/08 , H04L12/26 , G06F16/245
Abstract: A system may utilize a combination of real-time and polling connectors for data crawling. A real-time connector may use a collector to write data associated with a new event from a database to a channel and record external identifiers (IDs) associated the data. A polling connector may use a verifier to compare the recorded IDs with IDs associated with a batch of data, and may write any data of the batch of data to the channel that has not been written previously written by the collector. The system may include an onboarder for reading data previously stored in the database.
-
-
-
-
-
-