Ncr Corporation

Teradata Us, Inc.

Candle Distributed Solutions, Inc.

Alex P Yung

Gregory Korenevsky

Greg Korenevsky

Steven Feinholz

Bruce Wayne Britton

Sam Greenblatt

Clovis Franklin Lofton

Thomas Burlew

Stephen Feinholz

Techniques for asynchronous command processing within a parallel processing environment are provided. A command is raised or received within a parallel processing data warehousing environment. A job or a component of the job is dynamically monitored, controlled, or modified in response to the real-time processing of the command. The job is actively processing within the parallel processing data warehousing environment when the command is received and processed against the job or the component of the job.

Techniques for asynchronous command interface for scalable and active data warehousing

A method, computer program and computer system for collecting data from one or more data sources, into which data is continuously stored, and for loading the collected data into one or more data targets is disclosed. One or more events are defined and one or more rules are associated with each event. When one of the one or more events occurs, unmarked data is collected from the one or more data sources in accordance with the rules associated with the one event, the collected, unmarked data in the one or more data sources is marked, and the collected data is stored in one or more of the data targets.

Rule-based, event-driven, scalable data collection

A method and computer program for reducing the restart time for a parallel application are disclosed. The parallel application includes a plurality of parallel operators. The method includes repeating the following: setting a time interval to a next checkpoint; waiting until the time interval expires; sending checkpoint requests to each of the plurality of parallel operators; and receiving and processing messages from one or more of the plurality of parallel operators. The method also includes receiving a checkpoint. request message on a control data stream, waiting to enter a state suitable for checkpointing, and sending a response message on the control data stream.

Restartable database loads using parallel data streams

A method, computer program, and computer system for updating a database system using a parallel application are disclosed. The parallel application includes a plurality of parallel operators. The method includes receiving records. A unique identifier is assigned to each record. A user defined rule condition is evaluated for each record. An action identifier is assigned to a subset of the records, based on the evaluation of the user defined rule condition. The records are transmitted to the database system with the unique identifiers and, for each of the subset of records, action identifiers.

Restartable scalable database system updates with user defined rules

A method and apparatus enables a client system to perform multi-phase parallel operations upon data in a database system. A data transaction request received by the client system. A plurality of multi-phase parallel tasks are executed in response to the request to perform the data operations upon the data in the database.

Method and apparatus for performing parallel data operations

A method and computer program for reducing the restart time for a parallel application are disclosed. The parallel application includes a plurality of parallel operators. The method includes repeating the following: setting a time interval to a next checkpoint; waiting until the time interval expires; sending checkpoint requests to each of the plurality of parallel operators; and receiving and processing messages from one or more of the plurality of parallel operators. The method also includes receiving a checkpoint request message on a control data stream, waiting to enter a state suitable for checkpointing, and sending a response message on the control data stream.

A data server data base system applies a request for data to a data engine which launches a probe via network transport that causes the data to be collected on a remote platform and returned via network transport. The returned data is then applied to the requesting user application in the form of one or more rows of columnar data emulating the return of data from a conventional data base system including data tables. This operation may further be enhanced by the inclusion of Event processing in which the occurrence of an event based on a predicate test is determined by the data server without requiring attention of the user application. In particular, the user application stores a rule statement in the data server and then references that statement by name in a data inquiry. An event level data probe is invoked to collect the data referenced in the rule statement and the collected data is tested in accordance with the rule statement to determine if the event has occurred. Data passing the rule statement test is returned to the user application if the event is determined to have occurred unless Delta processing is invoked in which case only data representing a transition from Event true to Event false or Event false to Event true is returned.

Data server with event driven sampling

A data server data base system is enhanced by the inclusion of Event processing in which the occurrence of an event based on a predicate test is determined by the data server without requiring attention of the user application. In particular, the user application stores a rule statement in the data server and then references that statement by name in a data inquiry. An event level data probe is invoked to collect the data referenced in the rule statement and the collected data is tested in accordance with the rule statement to determine if the event has occurred. Data passing the rule statement test is returned to the user application if the event is determined to have occurred unless Delta processing is invoked in which case only data representing a transition from Event true to Event false or Event false to Event true is returned.

Growing community of inventors

Anaheim, CA, United States of America

Alex P Yung