System and method for performing distributed asynchronous calculations in a networked environment

• US 9,531,795 B2
• Filed: 04/23/2015
• Issued: 12/27/2016
• Est. Priority Date: 02/28/2013
• Status: Active Grant

• Current Assignee: Workiva Inc.
• Original Assignee: Workiva Inc.
• Inventors: Kluin, Robert A., Lyddon, Beau D.
• Primary Examiner(s): Etienne, Ario
• Assistant Examiner(s): RUBIN, BLAKE J
• Application Number:
  US14/694,417
• Publication Number:
  US 20150229721A1
• Time in Patent Office: 614 Days
• US Class Current: 1/1
• CPC Class Codes: G06F 16/2329 using versioning
• CPC Class Codes: G06F 16/235 Update request formulation
• CPC Class Codes: G06F 16/24564 Applying rules; Deductive queries
• CPC Class Codes: G06F 16/254 Extract, transform and load [ETL] procedures, e.g. ETL data flows in data warehouses
• CPC Class Codes: G06F 16/288 Entity relationship models
• CPC Class Codes: G06F 16/9017 using directory or table look-up use of a directory or look-up table in file systems G06F16/13
• CPC Class Codes: G06F 16/9024 Graphs; Linked lists G06F16/9027 takes precedence
• CPC Class Codes: G06F 40/18 of spreadsheets form-filling G06F40/174
• CPC Class Codes: G06F 9/546 Message passing systems or structures, e.g. queues
• CPC Class Codes: H04L 67/01 Protocols
• CPC Class Codes: H04L 67/10 in which an application is distributed across nodes in the network software deployment G06F8/60; multiprogramming arrangements G06F9/46
• CPC Class Codes: H04L 67/1095 Replication or mirroring of data, e.g. scheduling or transport for data synchronisation between network nodes

Abstract

A method and associated system are provided for performing calculations in a distributed networked environment, comprising: updating a source element on a first computer; sending a calculate update signal to a target calculated element for updating on a target element computer that may be the first computer or a second computer connected to the first computer that uses the source element in a calculation; obtaining the updated source element by a process on the target element computer associated with the target calculated element in response to the sending; and performing a calculation to update the target calculated element using the obtained updated source element.

Claims

1. A method for performing calculations in a distributed networked environment, comprising:

receiving, via a message queuing system, a first calculate update signal which is a first message generated in response to an update of a first source element, wherein the first message is specifically directed to a target calculated element to be updated on a target element computer and includes version information for the first source element;

receiving, via the message queuing system, a second calculate update signal which is a second message generated in response to an update of a second source element, wherein the second message is specifically directed to the target calculated element and contains version information for the second source element,

wherein calculation of the target calculated element depends on the first source element and on the second source element;

determining, based at least in part on the version information for the first source element and the version information for the second source element, whether the second message is redundant to the first message;

discarding the second message from the message queuing system if the second message is determined to be redundant to the first message;

in response to the first message, obtaining, by a processor on the target element computer, the updated first source element and the updated second source element; and

performing a calculation to update the target calculated element using the obtained updated first source element and updated second source element.

2. The method of claim 1, further comprising:

receiving, via the message queuing system, at least one additional calculate update signal in the form of an additional message generated in response to an additional update of an additional source element upon which the target calculated element depends,

wherein the additional message includes an element identifier of the additional source element;

determining that the at least one additional message is redundant by matching the element identifier of the additional message with an element identifier for a different update message in the messaging queuing system.

5. The method of claim 1, further comprising:

presenting viewable results of performing the calculation prior to the user sharing the update.

3. A method for performing calculations in a distributed networked environment, comprising:

receiving an update of a draft copy of a source element, wherein the draft copy of the source element is specific to a user of a plurality of users;

obtaining a draft copy of a target calculated element, wherein

the target calculated element depends on the source element in a calculation,

the target calculated element is shared among the plurality of users,

the draft copy of the target calculated element is specific to the user;

performing a calculation to update the draft copy of the target calculated element without updating the target calculated element;

in response to the user sharing the update of the draft copy of the source element with the plurality of users, updating the source element in accordance with the updated draft copy of the source element;

sending a calculate update signal which is a message communicated through a message queuing system in response to the updating, specifically directed to the target calculated element, wherein the target calculated element is calculated for updating on a target element computer, and the target element computer may be the first computer or a second computer connected to the first computer;

obtaining the updated source element by a processor on the target element computer associated with the target calculated element in response to the sending; and

performing a calculation to update the target calculated element using the obtained updated source element.

4. The method of claim 3, further comprising:

utilizing the updated target calculated element in a subsequent calculation.

6. The method of claim 3, further comprising:

obtaining draft copies of a plurality of target calculated elements that may be impacted by a change in the source element.

7. The method of claim 3, further comprising:

distributing the updated target calculated element across a plurality of computers.