×

Speculative data processing of streaming data

  • US 9,438,676 B2
  • Filed: 07/25/2014
  • Issued: 09/06/2016
  • Est. Priority Date: 07/25/2014
  • Status: Active Grant
First Claim
Patent Images

1. A computer system comprising:

  • a memory;

    a processor coupled to the memory;

    processing logic coupled to the memory and the processor and configured to;

    receive a plurality of source data records from one or more source computers, wherein one or more first source data records are associated with a first source transaction and one or more second source data records are associated with a second source transaction;

    generate a first derived transaction including one or more first derived records based on the plurality of source data records;

    generate a first transaction mapping between the first derived transaction and the first source transaction;

    generate a second transaction mapping between the first derived transaction and the second source transaction;

    determine that the first derived transaction has ended, and in response, commit first derived transaction including the one or more first derived records to a persistent storage;

    receive a first ending punctuation associated with the first source transaction, and in response, commit the first source transaction including the one or more first source data records associated with the first source transaction to the persistent storage;

    after committing the first derived transaction, determine that the second source transaction failed, and in response;

    determine that the first derived transaction should be regenerated based on the second transaction mapping, and in response, regenerate the first derived transaction by;

    generating one or more second derived records that are based on the one or more first source data records but not the one or more second source data records;

    committing the one or more second derived records to the persistent storage.

View all claims
  • 1 Assignment
Timeline View
Assignment View
    ×
    ×