公开(公告)号：WO2020068927A3

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

申请号：PCT/US2019/052882

申请日：2019-09-25

Applicant: AB INITIO TECHNOLOGY LLC ,  VEISER, Paul

Inventor： VEISER, Paul ,  MURPHY, Trevor

IPC: G06F11/14 ,  G06F11/30 ,  G06F11/34

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.

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

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