公开(公告)号：US20200183913A1

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

申请号：US16582319

申请日：2019-09-25

Applicant: Ab Initio Technology LLC

Inventor： Trevor Murphy ,  Paul Veiser

IPC: G06F16/23 ,  G06F16/901 ,  G06F11/14 ,  G06F9/46 ,  G06F16/2455

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.

公开(公告)号：US20240346051A1

公开(公告)日：2024-10-17

申请号：US18496543

申请日：2023-10-27

Applicant: Ab Initio Technology LLC

Inventor： Marshall A. Isman ,  Adam Weiss ,  Jonah Egenolf ,  Robert Parks ,  John MacLean ,  Richard Mellon ,  Dusan Radivojevic ,  Paul Veiser ,  Mazin Woodrow Khader

IPC: G06F16/28 ,  G06F3/048 ,  G06F9/448 ,  G06F9/451

CPC classification number: G06F16/288 ,  G06F3/048 ,  G06F9/4494 ,  G06F9/451

Abstract: A method implemented by a data processing system for enabling a system to pipeline or otherwise process data in conformance with specified criteria by providing a graphical user interface for selecting data to be processed, determining metadata of selected data, and, based on the metadata, automatically processing the selected data in conformance with the specified criteria.

公开(公告)号：US20170177446A1

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

申请号：US15360449

申请日：2016-11-23

Applicant: Ab Initio Technology LLC

Inventor： John MacLean ,  Paul Veiser

IPC: G06F11/14 ,  G06F17/30

CPC classification number: G06F11/1451 ,  G06F11/3082 ,  G06F11/3438 ,  G06F11/3476 ,  G06F16/21 ,  G06F16/23 ,  G06F16/24565 ,  G06F16/24568 ,  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.

公开(公告)号：US11989096B2

公开(公告)日：2024-05-21

申请号：US15360449

申请日：2016-11-23

Applicant: Ab Initio Technology LLC

Inventor： John MacLean ,  Paul Veiser

IPC: G06F11/14 ,  G06F11/30 ,  G06F11/34 ,  G06F16/21 ,  G06F16/23 ,  G06F16/2455 ,  G06F17/40

CPC classification number: G06F11/1451 ,  G06F11/3082 ,  G06F11/3438 ,  G06F11/3476 ,  G06F16/21 ,  G06F16/23 ,  G06F16/24565 ,  G06F16/24568 ,  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.

公开(公告)号：US11288258B2

公开(公告)日：2022-03-29

申请号：US16582319

申请日：2019-09-25

Applicant: Ab Initio Technology LLC

Inventor： Trevor Murphy ,  Paul Veiser

IPC: G06F16/00 ,  G06F16/23 ,  G06F16/2455 ,  G06F16/901 ,  G06F9/46 ,  G06F11/14 ,  G06Q10/10

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.