Matthew D Atterbury

8566641, Oct 22, 2013

Jun 14, 2012

13/523422

Bryan Phil Douros - Framingham MA, US
Matthew Darcy Atterbury - Lexington MA, US
Tim Wakeling - Andover MA, US

Ab Initio Technology LLC - Lexington MA

G06F 11/00

714 15, 714 16, 714 20

Among other aspects disclosed are a method and system for processing a batch of input data in a fault tolerant manner. The method includes reading a batch of input data including a plurality of records from one or more data sources and passing the batch through a dataflow graph. The dataflow graph includes two or more nodes representing components connected by links representing flows of data between the components. At least one but fewer than all of the components includes a checkpoint process for an action performed for each of multiple units of work associated with one or more of the records. The checkpoint process includes opening a checkpoint buffer stored in non-volatile memory at the start of processing for the batch.

20110016354, Jan 20, 2011

Jul 14, 2009

12/502851

Bryan Phil Douros - Framingham MA, US
Matthew Darcy Atterbury - Lexington MA, US
Tim Wakeling - Andover MA, US

G06F 11/00
G06F 9/46

714 16, 718101

Among other aspects disclosed are a method and system for processing a batch of input data in a fault tolerant manner. The method includes reading a batch of input data including a plurality of records from one or more data sources and passing the batch through a dataflow graph. The dataflow graph includes two or more nodes representing components connected by links representing flows of data between the components. At least one but fewer than all of the components includes a checkpoint process for an action performed for each of multiple units of work associated with one or more of the records. The checkpoint process includes opening a checkpoint buffer stored in non-volatile memory at the start of processing for the batch. For each unit of work from the batch, if a result from performing the action for the unit of work was previously saved in the checkpoint buffer, the saved result is used to complete processing of the unit of work without performing the action again. If a result from performing the action for the unit of work is not saved in the checkpoint buffer. The action is performed to complete processing of the unit of work and the result from performing the action is saved in the checkpoint buffer.

20110078500, Mar 31, 2011

Dec 15, 2009

12/638588

Bryan Phil Douros - Framingham MA, US
Matthew Darcy Atterbury - Lexington MA, US
Craig W. Stanfill - Lincoln MA, US
H. Mark Bromley - Lyndeborough NH, US

G06F 9/46
G06F 11/07

714 15, 718101, 714E11023

A graph-based computation has a plurality of nodes representing graph components connected by one or more links representing data flows between the components. Preparing the computation includes: identifying at least a first set of components to process a plurality of transactions in the computation; and associating with a first transaction a first group of one or more data records and data operations corresponding to the data records, and associating with a second transaction a second group of one or more data records and data operations corresponding to the data records. Executing the computation to process at least the first and second transactions includes delaying execution by the first set of components of a data operation corresponding to an initial data record of the second group until after execution by the first set of components of a data operation corresponding to a final data record of the first group.

20110307897, Dec 15, 2011

Jun 15, 2011

13/161010

Matthew Darcy Atterbury - Lexington MA, US
H. Mark Bromley - Lyndeborough NH, US
Wayne Mesard - Belmont MA, US
Arkadi Popov - Sharon MA, US
Stephen Schmidt - Medford MA, US
Craig W. Stanfill - Lincoln MA, US

G06F 9/46

718102

Processing data includes: receiving units of work that each include one or more work elements, and processing a first unit of work using a first compiled dataflow graph () loaded into a data processing system () in response to receiving the first unit of work. The processing includes: analysis to determine a characteristic of the first unit of work; identifying one or more compiled dataflow graphs from graphs stored in a data storage system () that include at least some that were compiled for processing a unit of work having the determined characteristic; loading one of the identified compiled dataflow graphs into the data processing system () as the first compiled dataflow graph (); and generating one or more output work elements from at least one work element in the first unit of work.

20140053159, Feb 20, 2014

Oct 18, 2013

14/057157

Matthew Darcy Atterbury - Lexington MA, US
Tim Wakeling - Andover MA, US

Ab Initio Technology LLC - Lexington MA

G06F 9/46

718101

Among other aspects disclosed are a method and system for processing a batch of input data in a fault tolerant manner. The method includes reading a batch of input data including a plurality of records from one or more data sources and passing the batch through a dataflow graph. The dataflow graph includes two or more nodes representing components connected by links representing flows of data between the components. At least one but fewer than all of the components includes a checkpoint process for an action performed for each of multiple units of work associated with one or more of the records. The checkpoint process includes opening a checkpoint buffer stored in non-volatile memory at the start of processing for the batch.

20190026210, Jan 24, 2019

Sep 21, 2018

16/137822

- Lexington MA, US
Michael G. Mulligan - Lexington MA, US
Tim Wakeling - Andover MA, US
Matthew Darcy Atterbury - Lexington MA, US

G06F 11/34
G06F 17/30
G06Q 30/02
G06Q 40/06

Methods, systems, and apparatus, including computer programs encoded on computer storage media, for dynamic graph performance monitoring. One of the methods includes receiving input data by the data processing system, the input data provided by an application executing on the data processing system. The method includes determining a characteristic of the input data. The method includes identifying, by the application, a dynamic component from multiple available dynamic components based on the determined characteristic, the multiple available dynamic components being stored in a data storage system. The method includes processing the input data using the identified dynamic component. The method also includes determining one or more performance metrics associated with the processing.

20140143757, May 22, 2014

Nov 16, 2012

13/678928

- Lexington MA, US
Michael G Mulligan - Lexington MA, US
Tim Wakeling - Andover MA, US
Matthew Darcy Atterbury - Lexington MA, US

Ab Initio Technology LLC - Lexington MA

G06F 9/44

717124

Methods, systems, and apparatus, including computer programs encoded on computer storage media, for dynamic graph performance monitoring. One of the methods includes receiving input data by the data processing system, the input data provided by an application executing on the data processing system. The method includes determining a characteristic of the input data. The method includes identifying, by the application, a dynamic component from multiple available dynamic components based on the determined characteristic, the multiple available dynamic components being stored in a data storage system. The method includes processing the input data using the identified dynamic component. The method also includes determining one or more performance metrics associated with the processing.

20140143760, May 22, 2014

Nov 16, 2012

13/678921

- Lexington MA, US
Michael G. Mulligan - Lexington MA, US
Tim Wakeling - Andover MA, US
Matthew Darcy Atterbury - Lexington MA, US

Ab Initio Technology LLC - Lexington MA

G06F 11/36

717132

Methods, systems, and apparatus, including computer programs encoded on computer storage media, for dynamic graph performance monitoring. One of the methods includes receiving multiple units of work that each include one or more work elements. The method includes determining a characteristic of the first unit of work. The method includes identifying, by a component of the first dataflow graph, a second dataflow graph from multiple available dataflow graphs based on the determined characteristic, the multiple available dataflow graphs being stored in a data storage system. The method includes processing the first unit of work using the second dataflow graph. The method includes determining one or more performance metrics associated with the processing.