Restartable scalable database system updates with user defined rules
First Claim
1. A method for updating a database system using a parallel application, the parallel application including a plurality of parallel operators, the method comprising:
- receiving records;
attaching a unique identifier to each record;
receiving one or more user defined rules;
generating an action and a user defined rule condition for each of the user defined rules;
assigning an action identifier to each action/user defined rule condition pair;
evaluating a first user defined rule condition for each record;
attaching first action identifier to a first subset of the records, based on the evaluation of the first user defined rule condition;
evaluating a second user defined rule condition for each record;
attaching a second action identifier to a second subset of the records, based on the evaluation of the second user defined rule condition;
transmitting the records to the database system with the unique identifiers and, for each of the first subset of the records, the first action identifiers;
transmitting the second action identifier to the database system with each of the second subset of the records; and
transmitting the one or more actions to the database system.
2 Assignments
0 Petitions
Accused Products
Abstract
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.
32 Citations
22 Claims
-
1. A method for updating a database system using a parallel application, the parallel application including a plurality of parallel operators, the method comprising:
-
receiving records; attaching a unique identifier to each record; receiving one or more user defined rules; generating an action and a user defined rule condition for each of the user defined rules; assigning an action identifier to each action/user defined rule condition pair; evaluating a first user defined rule condition for each record; attaching first action identifier to a first subset of the records, based on the evaluation of the first user defined rule condition; evaluating a second user defined rule condition for each record; attaching a second action identifier to a second subset of the records, based on the evaluation of the second user defined rule condition; transmitting the records to the database system with the unique identifiers and, for each of the first subset of the records, the first action identifiers; transmitting the second action identifier to the database system with each of the second subset of the records; and transmitting the one or more actions to the database system. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10)
-
-
11. A computer program, stored on a tangible storage medium, for use in updating a database system using a parallel application, the parallel application including a plurality of parallel operators, the computer program comprising executable instructions that cause a computer to:
-
receive records; attach a unique identifier to each record; receive one or more user defined rules; generate an action and a user defined rule condition for each of the user defined rules; assign an action identifier to each action/user defined rule condition pair; evaluate a first user defined rule condition for each record; attach first action identifier to a first subset of the records, based on the evaluation of the first user defined rule condition; evaluate a second user defined rule condition for each record; attach a second action identifier to a second subset of the records, based on the evaluation of the second user defined rule condition; transmit the records to the database system with the unique identifiers and, for each of the first subset of the records, the first action identifiers; transmit the second action identifier to the database system with each of the second subset of records; and transmit the one or more actions to the database system. - View Dependent Claims (12, 13, 14, 15, 16, 17, 18, 19, 20)
-
-
21. A computer system for use in updating a database system using a parallel application, the parallel application including a plurality of parallel operators, the computer system comprising:
-
a rule compiler adapted to receive one or more user defined rules, generate an action and a user defined rule condition for each of the user defined rules, and assign an action identifier to each action/user defined rule condition pair; one or more nodes; a plurality of CPUs, each of the one or more nodes providing access to one or more CPUs; a plurality of operators, each of the one or more CPUs providing access to one or more operators; one of the operators comprising a source record identifier generator adapted to receive records and attach a unique identifier to each record; one of the operators comprising a rule evaluator operator adapted to receive records, including attached unique identifiers, from the source record identifier generator, evaluate a first and a second user defined rule condition for each record, and attach a first action identifier to a first subset of the records based on the evaluation of the first user defined rule condition and attach a second action identifier to a second subset of the records based on the evaluation of the second user defined rule condition; one of the operators comprising an update operator adapted to receive records, including attached unique identifiers and attached action identifiers, from the rule evaluator operator; and a database system server adapted to receive records, including attached unique identifiers and attached action identifiers, actions, and an update identifier from the update operator. - View Dependent Claims (22)
-
Specification