公开(公告)号：WO2022165146A1

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

申请号：PCT/US2022/014270

申请日：2022-01-28

Applicant: AB INITIO TECHNOLOGY LLC

Inventor： GYLFASON, Halldor, Isak ,  PARKS, Robert

IPC: G06F16/25

Abstract: Techniques for obtaining information about data entity instances managed by a data processing system using at least one data store. The techniques include obtaining a query comprising a first portion comprising information for identifying instances of a first data entity stored in at least one data store; and a second portion indicating at least one attribute of the first data entity; generating, from the query, a plurality of executable queries including a first set of one or more executable queries and a second set of one or more executable queries, the generating comprising: generating, using the first portion, the first set of executable queries for identifying instances of the first data entity, and generating, using the second portion, the second set of executable queries for obtaining attribute values for instances of the first data entity; and executing the plurality of executable queries to obtain results for the query.

公开(公告)号：WO2022165123A8

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

申请号：PCT/US2022/014232

申请日：2022-01-28

Applicant: AB INITIO TECHNOLOGY LLC

Inventor： GYLFASON, Halldor, Isak ,  PARKS, Robert ,  RADIVOJEVIC, Dusan ,  WEISS, Adam, Harris

IPC: G06F16/22 ,  G06F16/21 ,  G06F16/211 ,  G06F16/24564 ,  G06F16/27 ,  G06F16/285 ,  G06F16/288

Abstract: Techniques for storing data entities by a data processing system are described herein. The data processing system may store a plurality of data entity instances generated using a plurality of data entities. The plurality of data entity instances may include a first data entity instance generated using a first data entity and a second data entity instance generated using a second data entity. The first data entity instance may include a first attribute that is configured to inherit its value from a second attribute of the second data entity instance. The data processing system may provide the inherited value of the second attribute of the second data entity instance as the value of the first attribute of the first data entity instance.

公开(公告)号：WO2021154319A1

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

申请号：PCT/US2020/030612

申请日：2020-04-30

Applicant: AB INITIO TECHNOLOGY LLC

Inventor： SCHECHTER, Ian ,  DICKIE, Garth

IPC: G06F8/34 ,  G06F8/41 ,  G06F8/30 ,  G06F8/36

Abstract: Techniques for generating a dataflow graph include generating a first dataflow graph with a plurality of first nodes representing first computer operations in processing data, with at least one of the first computer operations being a declarative operation that specifies one or more characteristics of one or more results of processing of data, and transforming the first dataflow graph into a second dataflow graph for processing data in accordance with the first computer operations, the second dataflow graph including a plurality of second nodes representing second computer operations, with at least one of the second nodes representing one or more imperative operations that implement the logic specified by the declarative operation, where the one or more imperative operations are unrepresented by the first nodes in the first dataflow graph.

公开(公告)号：WO2020068927A2

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

申请号：PCT/US2019/052882

申请日：2019-09-25

Applicant: AB INITIO TECHNOLOGY LLC ,  VEISER, Paul

Inventor： VEISER, Paul ,  MURPHY, Trevor

Abstract: A method implemented by a data processing system including: executing a dataflow graph that includes the plurality of components and the links, with a given component of the plurality including an input port, an audit port and an output port; processing, by the dataflow graph with the components and the links, the one or more data records representing the transaction, wherein the at least one of the components saves a state specifying one or more input records that are processed by the at least one of the components; when an error occurs during processing of one or more input records by the given component, restoring a state of the at least one of the components to the saved state; and based on the restored state, recovering at least some of the audit data for the given component of the dataflow graph.

公开(公告)号：WO2019231793A1

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

申请号：PCT/US2019/033573

申请日：2019-05-22

Applicant: AB INITIO TECHNOLOGY LLC

Inventor： DICKIE, Garth, Allen

IPC: G06F8/41 ,  G06F16/901

Abstract: At least one non-transitory computer-readable storage medium storing processor- executable instructions that, when executed by at least one computer hardware processor, cause the at least one computer hardware processor to perform: obtaining an automatically generated initial dataflow graph, the initial dataflow graph comprising a first plurality of nodes representing a first plurality of data processing operations and a first plurality of links representing flows of data among nodes in the first plurality of nodes; and generating an updated dataflow graph by iteratively applying dataflow graph optimization rules to update the initial dataflow graph, the updated dataflow graph comprising a second plurality of nodes representing a second plurality of data processing operations and a second plurality of links representing flows of data among nodes in the second plurality of nodes.

公开(公告)号：WO2019089606A1

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

申请号：PCT/US2018/058225

申请日：2018-10-30

Applicant: AB INITIO TECHNOLOGY LLC

Inventor： STANFILL, Craig W.

IPC: G06F9/52

Abstract: A method for processing state update requests in a distributed data processing system includes processing a set of state update requests associated with a first time interval including maintaining a count of issued state update requests for the set of state update requests, maintaining a count of state updates performed for the first set of state update requests, and updating a state consistency indicator to indicate that state updates associated with all state update requests of the first set of state update requests have been performed in response to determining that the count of state updates performed for the first set of state update requests equals the count of issued state update requests for the first set of state update requests.

公开(公告)号：WO2019089593A1

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

申请号：PCT/US2018/058211

申请日：2018-10-30

Applicant: AB INITIO TECHNOLOGY LLC

Inventor： STANFILL, Craig W. ,  WHOLEY, Joseph Skeffington, III

IPC: G06F9/50 ,  G06F9/54

Abstract: A method for processing state update requests in a distributed data processing system with a number of processing nodes includes maintaining a number of counters including a working counter indicating a current time interval, a replication counter indicating a time interval for which all requests associated with that time interval are replicated at multiple processing nodes of the number of processing nodes, and a persistence counter indicating a time interval of the number of time intervals for which all requests associated with that time interval are stored in persistent storage. The counters are used to manage processing of the state update requests.

公开(公告)号：WO2018156796A1

公开(公告)日：2018-08-30

申请号：PCT/US2018/019272

申请日：2018-02-22

Applicant: AB INITIO TECHNOLOGY LLC

Inventor： RAVID, Oded ,  ROSSI, Larry Paul ,  BAXTER, Peter ,  GOULD, Joel

IPC: G06F17/20

Abstract: A method is described for processing keyed data items that are each associated with a value of a key, the keyed data items being from a plurality of distinct data streams, the processing including collecting the keyed data items, determining, based on contents of at least one of the keyed data items, satisfaction of one or more specified conditions for execution of one or more actions and causing execution of at least one of the one or more actions responsive to the determining.

公开(公告)号：WO2017112697A1

公开(公告)日：2017-06-29

申请号：PCT/US2016/067840

申请日：2016-12-20

Applicant: AB INITIO TECHNOLOGY LLC

Inventor： MACLEAN, John ,  VEISER, Paul

IPC: G06F17/40 ,  G06F11/34 ,  G06F11/30

CPC classification number: G06F11/1451 ,  G06F11/3082 ,  G06F11/3438 ,  G06F11/3476 ,  G06F17/30289 ,  G06F17/30345 ,  G06F17/3051 ,  G06F17/30516 ,  G06F17/40 ,  G06F2201/84

Abstract: A method performed by a data processing system for processing data, the method including: intermittently receiving data from one or more data streams, the received data including data records; detecting two or more particular data records in the received data records, where the detected two or more particular data records each include a particular identifier; for that particular identifier, creating a collection of data records; for at least one particular data record included in the collection of data records, searching data records for a historical aggregation of data; and computing combined data; modifying a data record by inserting the combined data into a field of the data record and by inserting data from at least one of the data records in the collection into another field of the data record; based on applying the rules, writing to memory one or more instructions for initiation of one or more actions.

Abstract translation: 数据处理系统执行的用于处理数据的方法，所述方法包括：间歇地从一个或多个数据流接收数据，所接收的数据包括数据记录; 检测所接收的数据记录中的两个或更多个特定数据记录，其中检测到的两个或更多个特定数据记录每个都包括特定标识符; 为该特定标识符创建数据记录的集合; 对于包括在所述数据记录集合中的至少一个特定数据记录，搜索数据记录以获得数据的历史集合; 并计算组合数据; 通过将组合的数据插入到数据记录的字段并通过将来自集合中的至少一个数据记录的数据插入数据记录的另一个字段来修改数据记录; 基于应用规则，向存储器写入一条或多条启动一个或多个动作的指令。

公开(公告)号：WO2017105529A1

公开(公告)日：2017-06-22

申请号：PCT/US2016/017108

申请日：2016-02-09

Applicant: AB INITIO TECHNOLOGY LLC

Inventor： THOMAS, Ben

IPC: G06F11/20

CPC classification number: G06F11/2056 ,  G06F3/065 ,  G06F11/1662 ,  G06F11/1666 ,  G06F11/2079 ,  G06F11/2082 ,  G06F11/2094 ,  G06F12/023 ,  G06F12/0253 ,  G06F2201/855 ,  H04L67/1095 ,  H04L67/1097

Abstract: A data processing system configured to store a plurality of data entities in volatile memories of multiple different computing devices. The data processing system comprises a first computing device having a first volatile memory configured to store a first data entity; and a second computing device having a second volatile memory configured to store a copy of the first data entity. The first computing device is configured to perform: receiving an indication to update the first data entity; after receiving the indication, updating the first data entity in the first volatile memory, and providing to the second computing device an indication to update the copy of the first data entity; and providing an indication that the first data entity has been updated, after receiving information from the second computing device indicating that the copy of the first data entity has been updated in the second volatile memory.

Abstract translation: 数据处理系统，被配置为将多个数据实体存储在多个不同计算设备的易失性存储器中。 该数据处理系统包括第一计算设备，该第一计算设备具有被配置为存储第一数据实体的第一易失性存储器; 以及具有被配置为存储第一数据实体的副本的第二易失性存储器的第二计算设备。 第一计算设备被配置为执行：接收更新第一数据实体的指示; 在接收到所述指示之后，更新所述第一易失性存储器中的所述第一数据实体，并且向所述第二计算设备提供更新所述第一数据实体的所述副本的指示; 以及在从第二计算设备接收到指示第一数据实体的副本已经在第二易失性存储器中被更新的信息之后，提供第一数据实体已被更新的指示。