Patent ID: 7783601

Claim:
A method for propagating change records from an source entity to a sink entity, comprising: receiving, at the source entity, a plurality of records that belong to a plurality of transactions, wherein first records from a first transaction in the plurality of transactions are interleaved with one or more records from one or more different transactions in the plurality of transactions; ordering the plurality of records into a stream of ordered records such that the stream of ordered records contains a plurality of blocks of records and that all records that belong to a transaction are stored contiguously in a single block of records in the plurality of blocks in the stream; wherein each block of records in the plurality of blocks is assigned a correlation identifier; receiving, at the source entity, a particular correlation identifier from the sink entity, the particular correlation identifier being used to identifying a particular block of records in the plurality of blocks of records; and sending, starting from the particular block of records, the stream of ordered records from the source entity to the sink entity; wherein the method is performed by one or more computing devices.