公开(公告)号：US10685034B2

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

申请号：US15786448

申请日：2017-10-17

Applicant: salesforce.com, inc.

Inventor： Ruisheng Shi ,  Santanu Sinha ,  Alex Gitelman

IPC: G06F16/00 ,  G06F16/25 ,  G06F9/38 ,  H04L29/08 ,  G06F9/30 ,  G06F16/27

Abstract: In accordance with disclosed embodiments, there are provided systems, methods, and apparatuses for implementing concurrent dataflow execution with write conflict protection within a cloud based computing environment. For instance, an exemplary system having at least a processor and a memory therein includes means for: creating a dataflow definition for a first dataflow type, wherein the dataflow definition includes at least one or more datasets to be accessed by the dataflow and a plurality of functional operations to be performed on the one or more datasets when the dataflow is executed; generating and storing a dataflow version identifying all datasets accessed by the dataflow based on the dataflow definition created; receiving multiple requests for the first dataflow type; enqueuing the multiple requests into a message queue pending execution; selecting, from the message queue, a first runnable dataflow having been earliest enqueued of the first dataflow type for execution based on (i) the first dataflow type being allowable within system limits and based further on (ii) verification that the selected first runnable dataflow is not already executing and based further on (iii) verification there is no write conflict for any dataset accessed by the selected first runnable dataflow. Other related embodiments are disclosed.

公开(公告)号：US11232123B2

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

申请号：US16689705

申请日：2019-11-20

Applicant: salesforce.com, inc.

Inventor： Alex Gitelman ,  Ruisheng Shi

IPC: G06F16/25 ,  G06F16/23 ,  G06F16/2453

Abstract: The technology disclosed relates to creating and frequently updating multiple online analytic processing (OLAP) analytic databases from an online transaction processing (OLTP) transaction updatable system that includes transaction commit, rollback, and field level security capabilities. It also relates to transparently decoupling extraction from rebuilding of frequently updated OLAP analytic databases from the OLTP transaction updatable system.

公开(公告)号：US10515089B2

公开(公告)日：2019-12-24

申请号：US15589728

申请日：2017-05-08

Applicant: salesforce.com, inc.

Inventor： Alex Gitelman ,  Ruisheng Shi

IPC: G06F16/25 ,  G06F16/23 ,  G06F16/2453

Abstract: The technology disclosed relates to creating and frequently updating multiple online analytic processing (OLAF) analytic databases from an online transaction processing (OLTP) transaction updatable system that includes transaction commit, rollback, and field level security capabilities. It also relates to transparently decoupling extraction from rebuilding of frequently updated OLAP analytic databases from the OLTP transaction updatable system.

公开(公告)号：US20190155642A1

公开(公告)日：2019-05-23

申请号：US15817582

申请日：2017-11-20

Applicant: salesforce.com, inc.

Inventor： Ruisheng Shi ,  Farid Nabavi ,  Alex Gitelman

IPC: G06F9/48

Abstract: System and methods for implementing dataflow life cycles are described and include forming, by a first server computing system, a dataflow life cycle by associating a dataflow with a customized code; associating, by the first server computing system, the customized code of the dataflow life cycle with context information, the customized code including one or more of pre-processing customized code and post-processing customized code; scheduling, by the first server computing system, the dataflow of the dataflow life cycle to be executed by a second server computing system when the customized code includes the pre-processing customized code and when the pre-processing customized code is successfully executed by the first server computing system; and executing, by the first server computing system, the post-processing customized code when the customized code includes the post-processing customized code and when the dataflow of the dataflow life cycle is successfully executed by the second server computing system.

公开(公告)号：US20190114350A1

公开(公告)日：2019-04-18

申请号：US15786448

申请日：2017-10-17

Applicant: salesforce.com, inc.

Inventor： Ruisheng Shi ,  Santanu Sinha ,  Alex Gitelman

IPC: G06F17/30 ,  G06F9/38 ,  H04L29/08 ,  G06F9/30

CPC classification number: G06F16/254 ,  G06F9/3005 ,  G06F9/3855 ,  G06F16/27 ,  H04L67/1095 ,  H04L67/1097

Abstract: In accordance with disclosed embodiments, there are provided systems, methods, and apparatuses for implementing concurrent dataflow execution with write conflict protection within a cloud based computing environment. For instance, an exemplary system having at least a processor and a memory therein includes means for: creating a dataflow definition for a first dataflow type, wherein the dataflow definition includes at least one or more datasets to be accessed by the dataflow and a plurality of functional operations to be performed on the one or more datasets when the dataflow is executed; generating and storing a dataflow version identifying all datasets accessed by the dataflow based on the dataflow definition created; receiving multiple requests for the first dataflow type; enqueuing the multiple requests into a message queue pending execution; selecting, from the message queue, a first runnable dataflow having been earliest enqueued of the first dataflow type for execution based on (i) the first dataflow type being allowable within system limits and based further on (ii) verification that the selected first runnable dataflow is not already executing and based further on (iii) verification there is no write conflict for any dataset accessed by the selected first runnable dataflow. Other related embodiments are disclosed.

公开(公告)号：US10853131B2

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

申请号：US15817582

申请日：2017-11-20

Applicant: salesforce.com, inc.

Inventor： Ruisheng Shi ,  Farid Nabavi ,  Alex Gitelman

IPC: G06F9/48

Abstract: System and methods for implementing dataflow life cycles are described and include forming, by a first server computing system, a dataflow life cycle by associating a dataflow with a customized code; associating, by the first server computing system, the customized code of the dataflow life cycle with context information, the customized code including one or more of pre-processing customized code and post-processing customized code; scheduling, by the first server computing system, the dataflow of the dataflow life cycle to be executed by a second server computing system when the customized code includes the pre-processing customized code and when the pre-processing customized code is successfully executed by the first server computing system; and executing, by the first server computing system, the post-processing customized code when the customized code includes the post-processing customized code and when the dataflow of the dataflow life cycle is successfully executed by the second server computing system.