公开(公告)号：US09304807B2

公开(公告)日：2016-04-05

申请号：US14057157

申请日：2013-10-18

Applicant: Ab Initio Technology LLC

Inventor： Bryan Phil Douros ,  Matthew Darcy Atterbury ,  Tim Wakeling

IPC: G06F11/00 ,  G06F9/46 ,  G06F11/14

CPC classification number: G06F9/46 ,  G06F11/1438 ,  G06F11/1471

Abstract: 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.

公开(公告)号：US20140164495A1

公开(公告)日：2014-06-12

申请号：US14180628

申请日：2014-02-14

Applicant: Ab Initio Technology LLC

Inventor： Jennifer M. Farver ,  Joshua Goldshlag ,  David W. Parmenter ,  Ian Schechter ,  Tim Wakeling

IPC: H04L29/06

CPC classification number: H04L43/04 ,  G06F8/71 ,  G06F9/54 ,  G06F16/9024 ,  H04L67/42

Abstract: A method for supporting communication between a client and a server includes receiving a first message from a client. The method also includes creating an object in response to the first message. The method also includes sending a response to the first message to the client. The method also includes receiving changes to the object from a server. The method also includes storing the changes to the object. The method also includes receiving a second message from the client. The method also includes sending the stored changes to the client with a response to the second message.

Abstract translation: 支持客户端与服务器之间的通信的方法包括从客户端接收第一消息。 该方法还包括响应于第一消息创建对象。 该方法还包括向客户端发送对第一消息的响应。 该方法还包括从服务器接收对象的更改。 该方法还包括将更改存储到对象。 该方法还包括从客户端接收第二消息。 该方法还包括将所存储的改变发送给客户机以对第二消息的响应。

公开(公告)号：US20140143757A1

公开(公告)日：2014-05-22

申请号：US13678928

申请日：2012-11-16

Applicant: AB INITIO TECHNOLOGY LLC

Inventor： Mark Buxbaum ,  Michael G Mulligan ,  Tim Wakeling ,  Matthew Darcy Atterbury

IPC: G06F9/44

CPC classification number: G06F11/3409 ,  G06F11/3452 ,  G06F17/30516 ,  G06F2201/865 ,  G06Q30/0201 ,  G06Q40/06

Abstract: 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.

Abstract translation: 方法，系统和装置，包括在计算机存储介质上编码的计算机程序，用于动态图表性能监视。 方法之一包括由数据处理系统接收输入数据，由在数据处理系统上执行的应用提供的输入数据。 该方法包括确定输入数据的特性。 该方法包括基于所确定的特性，由应用程序识别来自多个可用动态组件的动态组件，所述多个可用动态组件被存储在数据存储系统中。 该方法包括使用所识别的动态分量处理输入数据。 该方法还包括确定与该处理相关联的一个或多个性能度量。

公开(公告)号：US20140053159A1

公开(公告)日：2014-02-20

申请号：US14057157

申请日：2013-10-18

Applicant: Ab Initio Technology LLC

Inventor： Bryan Phil Douros ,  Matthew Darcy Atterbury ,  Tim Wakeling

IPC: G06F9/46

CPC classification number: G06F9/46 ,  G06F11/1438 ,  G06F11/1471

Abstract: 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.

Abstract translation: 公开的其它方面是用于以容错方式处理一批输入数据的方法和系统。 该方法包括从一个或多个数据源读取一批包括多个记录的输入数据，并将批次传递通过数据流图。 数据流图包括两个或更多个节点，表示通过表示组件之间的数据流的链接连接的组件。 至少一个但少于所有组件包括针对与一个或多个记录相关联的多个工作单元中的每一个执行的动作的检查点过程。 检查点过程包括在批处理开始时打开存储在非易失性存储器中的检查点缓冲区。