-
11.发明申请公开(公告)号：US20220035829A1
公开(公告)日：2022-02-03
申请号：US16943314
申请日：2020-07-30
Applicant: salesforce.com, inc.
Inventor： Zhidong Ke , Utsavi Benani , Kevin Terusaki , Yifeng Liu , Percy Mehta , Heng Zhang
Abstract: Managing mutations in a data lake environment. A mutation request to cause write operations that modify data objects or structures within an environment for collecting unformatted raw data is received. The environment has at least a data table and a notification table. An entry is written to the data table with a streaming job configured to receive and process the mutation request. Entries to the data table specify at least records indicating changes to objects in the environment based on ingestion processing for the environment for collecting unformatted raw data and based on the mutation request. A corresponding entry is written to the notification table in response to a successful write attempt to the data table. The notification table entry has information about data table entries for a specified period. At least one data consumer is notified that the data table has been modified.
-
12.发明申请公开(公告)号：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.
-
Search Results
12
records
(took 0.016 seconds)
