×

Scalable cloud-based time series analysis

  • US 10,503,498 B2
  • Filed: 05/22/2019
  • Issued: 12/10/2019
  • Est. Priority Date: 11/16/2017
  • Status: Active Grant
First Claim
Patent Images

1. A system comprising:

  • one or more data processors associated with a plurality of computing devices; and

    a non-transitory computer-readable storage medium comprising instructions that are executable by the one or more data processors for causing the plurality of computing devices to;

    read timestamped data and partition the timestamped data into a plurality of groups according to a criterion;

    distribute the timestamped data among the plurality of computing devices based on the plurality of groups;

    obtain copies of a script configured to process the timestamped data, each computing device among the plurality of computing devices receiving a copy of the script;

    determine one or more code segments associated with the plurality of groups based on content of the script, the one or more code segments being in one or more programming languages that are different than a programming language of the script; and

    run the copies of the script to process the timestamped data within the plurality of groups, each copy of the script being run on the timestamped data in a respective group among the plurality of groups at least in part by interacting with a job server configured to run a respective code segment associated with the respective group, the job server being compatible with a particular programming language of the respective code segment and being configured to run the respective code segment to generate respective model values associated with the respective group by;

    generating header code in the particular programming language, the header code defining one or more global variables having values provided in the script;

    generating footer code in the particular programming language, the footer code defining one or more output routines for returning the respective model values associated with the respective group;

    generating a modified code segment by combining the header code and the footer code with the respective code segment; and

    running the modified code segment based on the timestamped data in the respective group, thereby generating and returning the respective model values associated with the respective group.

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