US5870760A
Expired / Lapsed
US
⏱️ 0.0 years remaining
Dequeuing using queue batch numbers
Assignee: Oracle International Corp
•
Filing: 1996-12-19
•
Granted: 1999-02-09
•
Expires: 2016-12-19
Abstract
Abstract A method and system are provided for processing records from a set of records, where records are repeatedly being added to the set of records, and where each record in the set of records has to be processed once for each of a plurality of entities. According to the method, each record that is added to the set of records is marked with a default batch value. For each entity of the plurality of entities, a batch of the records is processed by performing the steps of: reading a last batch value associated with the entity, processing the records in the set of records that are marked with batch values that are more recent than the last batch value associated with the entity, and updating the last batch value associated with the entity to a most recent batch value of the records processed for the entity. Between processing consecutive batches for an entity of the plurality of entities, the set of records are marked by performing the steps of: updating a batch counter value to reflect a more recent batch number; and marking all records in the set of records that have the default batch value with the batch counter value.
Inventors
- 👤 Alan Demers
- 👤 Sandeep Jain
Bibliographic Details
Application Number
—
Jurisdiction
US
Data Source
google_patents
Last Synchronized
2026-11-04 03:59
CPC Classifications
G; G06; G06F; G06F16/00; G06F16/20; G06F16/23; G06F16/2308; G06F16/2336; G06F16/2343; G06F16/27; Y; Y10; Y10S; Y10S707/00; Y10S707/99951; Y10S707/99952; Y10S707/99953
Claims Analysis
Total Claims: 33
Claim 1
Independent Claim
197 words
A method for processing records that belong to a set of records, where records are repeatedly being added to said set of records, where each record in said set of records has to be processed once for each of a plurality of entities, the method comprising the steps of: marking each record that is added to said set of records with a default batch value; for each entity of said plurality of entities, processing a batch of said records by performing the steps of: reading a last batch value associated with said entity; processing the records in said set of records that are marked with batch values that are more recent than said last batch value associated with said entity; and updating the last batch value associated with said entity to a most recent batch value of the records processed for said entity; between processing consecutive batches for an entity of said plurality of entities, marking said set of records by performing the steps of: updating a batch counter value to reflect a more recent batch number; and marking all records in said set of records that have said default batch value with said batch counter value.
Claim 2
Independent Claim
197 words
A method for processing records that belong to a set of records, where records are repeatedly being added to said set of records, where each record in said set of records has to be processed once for each of a plurality of entities, the method comprising the steps of: marking each record that is added to said set of records with a default batch value; for each entity of said plurality of entities, processing a batch of said records by performing the steps of: reading a last batch value associated with said entity; processing the records in said set of records that are marked with batch values that are more recent than said last batch value associated with said entity; and updating the last batch value associated with said entity to a most recent batch value of the records processed for said entity; between processing consecutive batches for an entity of said plurality of entities, marking said set of records by performing the steps of: updating a batch counter value to reflect a more recent batch number; and marking all records in said set of records that have said default batch value with said batch counter value.
Claim 3
Dependent Claim
230 words
The method of claim 1 wherein: the plurality of entities is a plurality of destination sites; the set of records is a deferred transaction queue where each record corresponds to a set of changes to be propagated to one or more of said plurality of destination sites; the step of marking each record that is added to said set of records with a default batch value includes marking each record that is added to said deferred transaction queue with a default batch value; the step of reading a last batch value associated with said entity includes the step of reading a last batch value associated with a destination site of said plurality of destination sites; the step of processing the records in said set that are marked with batch values that are more recent than said last batch value associated with said entity includes the step of dequeuing for said destination site the records in said set that are marked with batch values that are more recent than said last batch value associated with said destination site; and the step of updating the last batch value associated with said entity to a most recent batch value of the records processed for said entity includes the step of updating the last batch value associated with said destination site to a highest batch value of the records dequeued for said destination site.
Claim 4
Dependent Claim
27 words
The method of claim 2 wherein: said deferred transaction queue comprises a table; and the step of dequeuing is performed by executing a query on said table.
Claim 5
Dependent Claim
38 words
The method of claim 2 wherein: each record includes a prepared time; and the step of processing a batch of said record further includes the step of sorting said records in said batch based on said prepared time.
Claim 6
Dependent Claim
29 words
The method of claim 1 wherein the step of marking said set of records is performed every time the step of processing a batch of said records is performed.
Claim 7
Dependent Claim
28 words
The method of claim 1 wherein the step of processing a batch of said records is performed by a different process for each of said plurality of entities.
Claim 8
Dependent Claim
26 words
The method of claim 1 further comprising the step of initializing said batch counter value to a value that is greater than said default batch value.
Claim 9
Independent Claim
141 words
A method for processing records that have been added to a set of records, where records are repeatedly being added to said set of records, where each record in said set of records has to be processed once for each of a plurality of entities, the method comprising the steps of: assigning each record that is added to said set of records to a temporary batch that is marked older than any prior batch; for each entity of said plurality of entities, processing said records by repeatedly performing the steps of: determining a last batch processed for said entity; and processing the records in all batches that are newer than said last batch processed for said entity; and between processing said records twice for an entity of said plurality of entities, marking said temporary batch as newer than any prior batch.
Claim 10
Independent Claim
141 words
A method for processing records that have been added to a set of records, where records are repeatedly being added to said set of records, where each record in said set of records has to be processed once for each of a plurality of entities, the method comprising the steps of: assigning each record that is added to said set of records to a temporary batch that is marked older than any prior batch; for each entity of said plurality of entities, processing said records by repeatedly performing the steps of: determining a last batch processed for said entity; and processing the records in all batches that are newer than said last batch processed for said entity; and between processing said records twice for an entity of said plurality of entities, marking said temporary batch as newer than any prior batch.
Claim 11
Dependent Claim
113 words
The method of claim 8 wherein: the step of assigning each record that is added to said set of records to a temporary batch that is marked older than any prior batch includes the step of adding a default batch number to each record; the step of determining a last batch processed for said entity includes the step of reading a last batch number for said entity; the step of processing the records in all batches that are newer than said last batch processed for said entity includes the step of processing all records that have been marked with batch numbers that are more recent than the last batch number for said entity.
Claim 12
Dependent Claim
54 words
The method of claim 9 further comprising the steps of: maintaining a batch number counter; wherein the step of marking said temporary batch as newer than any prior batch includes the steps of: incrementing the batch number counter; and assigning the batch number counter to all records that currently contain the default batch number.
Claim 13
Dependent Claim
69 words
The method of claim 8 wherein: the plurality of entities are destination sites to which changes must be replicated; and the step of processing said records for each of said entities includes, for each destination site, repeatedly performing the steps of: determining a last batch processed for said destination site; and processing the records in all batches that are newer than said last batch processed for said destination site.
Claim 14
Dependent Claim
66 words
The method of claim 11 wherein: the step of processing the records in all batches that are newer than said last batch processed for said destination site includes placing in a data container entries for transactions associated with said records; and the method further comprises the step of propagating to the destination site changes made by the transactions represented by said entries in the data container.
Claim 15
Dependent Claim
152 words
A computer-readable medium having stored thereon sequences of instructions for processing records that have been added to a set of records, where records are repeatedly being added to said set of records, where each record in said set of records has to be processed once for each of a plurality of entities, the sequences of instructions including sequences of instructions for performing the steps of: assigning each record that is added to said set of records to a temporary batch that is marked older than any prior batch; for each of said entities, processing said records by repeatedly performing the steps of: determining a last batch processed for said entity; and processing the records in all batches that are newer than said last batch processed for said entity; and between processing said records twice for an entity of said plurality of entities, marking said temporary batch as newer than any prior batch.
Claim 16
Dependent Claim
152 words
A computer-readable medium having stored thereon sequences of instructions for processing records that have been added to a set of records, where records are repeatedly being added to said set of records, where each record in said set of records has to be processed once for each of a plurality of entities, the sequences of instructions including sequences of instructions for performing the steps of: assigning each record that is added to said set of records to a temporary batch that is marked older than any prior batch; for each of said entities, processing said records by repeatedly performing the steps of: determining a last batch processed for said entity; and processing the records in all batches that are newer than said last batch processed for said entity; and between processing said records twice for an entity of said plurality of entities, marking said temporary batch as newer than any prior batch.
Claim 17
Dependent Claim
114 words
The computer-readable medium of claim 13 wherein: the step of assigning each record that is added to said set of records to a temporary batch that is marked older than any prior batch includes the step of adding a default batch number to each record; the step of determining a last batch processed for said entity includes the step of reading a last batch number for said entity; the step of processing the records in all batches that are newer than said last batch processed for said entity includes the step of processing all records that have been marked with batch numbers that are more recent than the last batch number for said entity.
Claim 18
Dependent Claim
60 words
The computer-readable medium of claim 14 further comprising sequences of instructions for performing the steps of: maintaining a batch number counter; wherein the step of marking said temporary batch as newer than any prior batch includes the steps of: incrementing the batch number counter; and assigning the batch number counter to all records that currently contain the default batch number.
Claim 19
Dependent Claim
70 words
The computer-readable medium of claim 13 wherein: the plurality of entities are destination sites to which changes must be replicated; and the step of processing said records for each of said entities includes, for each destination site, repeatedly performing the steps of: determining a last batch processed for said destination site; and processing the records in all batches that are newer than said last batch processed for said destination site.
Claim 20
Dependent Claim
73 words
The computer-readable medium of claim 16 wherein: the step of processing the records in all batches that are newer than said last batch processed for said destination site includes placing in a data structure entries for transactions associated with said records; and the computer-readable medium further comprises sequences of instructions for performing the step of propagating to the destination site changes made by the transactions represented by said entries in the data structure.
Claim 21
Independent Claim
118 words
A method for processing records that have been added to a set of records, where records are repeatedly being added to said set of records, where each record in said set of records has to be processed once for each of a plurality of entities, the method comprising the steps of: assigning each record that is added to said set of records to a temporary batch that is marked older than any prior batch; processing for an entity of said plurality of entities the records in all batches that are newer than a last batch processed for said entity; and before processing said records again for said entity, marking said temporary batch as newer than any prior batch.
Claim 22
Independent Claim
118 words
A method for processing records that have been added to a set of records, where records are repeatedly being added to said set of records, where each record in said set of records has to be processed once for each of a plurality of entities, the method comprising the steps of: assigning each record that is added to said set of records to a temporary batch that is marked older than any prior batch; processing for an entity of said plurality of entities the records in all batches that are newer than a last batch processed for said entity; and before processing said records again for said entity, marking said temporary batch as newer than any prior batch.
Claim 23
Dependent Claim
77 words
The method of claim 18 wherein: the plurality of entities are destination sites to which changes must be replicated; and the step of processing for said entity the records in all batches that are newer than a last batch processed for said entity includes repeatedly performing the steps of: determining a last batch processed for a destination site; and processing the records in all batches that are newer than said last batch processed for said destination site.
Claim 24
Dependent Claim
211 words
A computer-readable medium having stored thereon sequences of instructions for processing records that belong to a set of records, where records are repeatedly being added to said set of records, where each record in said set of records has to be processed once for each of a plurality of entities, the sequences of instructions including sequences of instructions for performing the steps of: marking each record that is added to said set of records with a default batch value; for each entity of said plurality of entities, processing a batch of said records by performing the steps of: reading a last batch value associated with said entity; processing the records in said set of records that are marked with batch values that are more recent than said last batch value associated with said entity; and updating the last batch value associated with said entity to a most recent batch value of the records processed for said entity; between processing consecutive batches for an entity of said plurality of entities, marking said set of records by performing the steps of: updating a batch counter value to reflect a more recent batch number; and marking all records in said set of records that have said default batch value with said batch counter value.
Claim 25
Dependent Claim
211 words
A computer-readable medium having stored thereon sequences of instructions for processing records that belong to a set of records, where records are repeatedly being added to said set of records, where each record in said set of records has to be processed once for each of a plurality of entities, the sequences of instructions including sequences of instructions for performing the steps of: marking each record that is added to said set of records with a default batch value; for each entity of said plurality of entities, processing a batch of said records by performing the steps of: reading a last batch value associated with said entity; processing the records in said set of records that are marked with batch values that are more recent than said last batch value associated with said entity; and updating the last batch value associated with said entity to a most recent batch value of the records processed for said entity; between processing consecutive batches for an entity of said plurality of entities, marking said set of records by performing the steps of: updating a batch counter value to reflect a more recent batch number; and marking all records in said set of records that have said default batch value with said batch counter value.
Claim 26
Dependent Claim
231 words
The computer-readable medium of claim 20 wherein: the plurality of entities is a plurality of destination sites; the set of records is a deferred transaction queue where each record corresponds to a set of changes to be propagated to one or more of said plurality of destination sites; the step of marking each record that is added to said set of records with a default batch value includes marking each record that is added to said deferred transaction queue with a default batch value; the step of reading a last batch value associated with said entity includes the step of reading a last batch value associated with a destination site of said plurality of destination sites; the step of processing the records in said set that are marked with batch values that are more recent than said last batch value associated with said entity includes the step of dequeuing for said destination site the records in said set that are marked with batch values that are more recent than said last batch value associated with said destination site; and the step of updating the last batch value associated with said entity to a most recent batch value of the records processed for said entity includes the step of updating the last batch value associated with said destination site to a highest batch value of the records dequeued for said destination site.
Claim 27
Dependent Claim
28 words
The computer-readable medium of claim 21 wherein: said deferred transaction queue comprises a table; and the step of dequeuing is performed by executing a query on said table.
Claim 28
Dependent Claim
39 words
The computer-readable medium of claim 21 wherein: each record includes a prepared time; and the step of processing a batch of said record further includes the step of sorting said records in said batch based on said prepared time.
Claim 29
Dependent Claim
30 words
The computer-readable medium of claim 20 wherein the step of marking said set of records is performed every time the step of processing a batch of said records is performed.
Claim 30
Dependent Claim
29 words
The computer-readable medium of claim 20 wherein the step of processing a batch of said records is performed by a different process for each of said plurality of entities.
Claim 31
Dependent Claim
30 words
The computer-readable medium of claim 20 further comprising instructions for performing the step of initializing said batch counter value to a value that is greater than said default batch value.
Claim 32
Independent Claim
220 words
A system for processing records, the system comprising: a plurality of entities; a scheduler heap containing a set of records, wherein records are repeatedly being added to said set of records; a propagation mechanism, wherein the propagation mechanism is configured to process each record in said set of records, wherein each record in said set of records is processed once for each of the plurality of entities by performing the steps of: marking each record that is added to said set of records with a default batch value; for each entity of said plurality of entities, processing a batch of said records by performing the steps of: reading a last batch value associated with said entity; processing the records in said set of records that are marked with batch values that are more recent than said last batch value associated with said entity; and updating the last batch value associated with said entity to a most recent batch value of the records processed for said entity; between processing consecutive batches for an entity of said plurality of entities, marking said set of records by performing the steps of: updating a batch counter value to reflect a more recent batch number; and marking all records in said set of records that have said default batch value with said batch counter value.
Claim 33
Independent Claim
220 words
A system for processing records, the system comprising: a plurality of entities; a scheduler heap containing a set of records, wherein records are repeatedly being added to said set of records; a propagation mechanism, wherein the propagation mechanism is configured to process each record in said set of records, wherein each record in said set of records is processed once for each of the plurality of entities by performing the steps of: marking each record that is added to said set of records with a default batch value; for each entity of said plurality of entities, processing a batch of said records by performing the steps of: reading a last batch value associated with said entity; processing the records in said set of records that are marked with batch values that are more recent than said last batch value associated with said entity; and updating the last batch value associated with said entity to a most recent batch value of the records processed for said entity; between processing consecutive batches for an entity of said plurality of entities, marking said set of records by performing the steps of: updating a batch counter value to reflect a more recent batch number; and marking all records in said set of records that have said default batch value with said batch counter value.
References Cited (Backward Citations)
US4432057A
Cited
US4551830A
Cited
US5058051A
Cited
US5347653A
Cited
US5463772A
Cited
US5383186A
Cited
US5689506A
Cited
USPTO Annuity & Maintenance Windows
| Annuity Stage | Window Opens | Payment Deadline | Surcharge Period Until | Estimated Fee | Status |
|---|---|---|---|---|---|
| 3.5 Years (Year 4) | 2002-02-08 | 2002-08-10 | 2003-02-09 | $2000.00 | Window Closed / Lapsed |
| 7.5 Years (Year 8) | 2006-02-08 | 2006-08-10 | 2007-02-09 | $3760.00 | Window Closed / Lapsed |
| 11.5 Years (Year 12) | 2010-02-08 | 2010-08-10 | 2011-02-09 | $7700.00 | Window Closed / Lapsed |