# US 9,438,485 B1 · State machine controlled dynamic distributed computing > Agents: this data is available as JSON from the patentgrep API and MCP server — see https://patentgrep.com/llms.txt - Number: US 9,438,485 B1 - Document ID: US9438485B1 - Status: Granted - Kind: B1 - Application number: 14/622,569 - Filed: 2015-02-13 - Granted: 2016-09-06 - Earliest claimed: 2008-02-08 - Assignees: Joviandata, Inc. - Applicants: Joviandata, Inc. - Inventors: Parveen Jain; Satya Ramachandran; Sushil Thomas; Anupam Singh - Web page: https://patentgrep.com/patent/US9438485B1 ## CPC - H04L 41/5025: by proactively reacting to service quality change, e.g. by reconfiguration after service quality degradation or upgrade - H04L 41/5009: Determining service level performance parameters or violations of service level contracts, e.g. violations of agreed response time or mean time between failures [MTBF] - H04L 41/5054: Automatic deployment of services triggered by the service manager, e.g. service implementation by automatic configuration of network components - H04L 67/10: in which an application is distributed across nodes in the network (software deployment G06F8/60; multiprogramming arrangements G06F9/46) - H04L 67/51: Discovery or management thereof, e.g. service location protocol [SLP] or web services - H04L 43/16: Threshold monitoring - H04L: TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION (arrangements common to telegraphic and telephonic communication H04M) ## Abstract A computer readable storage medium with executable instructions specifies the execution of a state machine operating across a set of computing nodes in a distributed computing system. The executable instructions execute a set of operators, where the execution of each operator is under the control of a state machine that periodically invokes pause control states to pause the execution of an operator in response to a violation of a service level agreement specifying an operating condition threshold within the distributed computing system. Partitions of input data are formed that are worked on independently within the distributed computing system. A set of data batches associated with the input data is processed. Data partition control states to process the partitions associated with the set of data batches are specified. Key control states to process a set of keys associated with a data partition of the partitions are defined. ## Claims ### Claim 1 A non-transitory computer readable storage medium with executable instructions specifying the execution of a state machine operating across a plurality of computing nodes in a distributed computing system, comprising executable instructions to: execute a plurality of operators, wherein the execution of each operator is under the control of a state machine that periodically invokes pause control states to pause the execution of an operator in response to a violation of a service level agreement specifying an operating condition threshold within the distributed computing system; form partitions of input data that are worked on independently within the distributed computing system; process a set of data batches associated with the input data; specify data partition control states to process the partitions associated with the set of data batches; and define key control states to process a set of keys associated with a data partition of the partitions. ### Claim 2 (depends on 1) The non-transitory computer readable storage medium of claim 1 wherein the state machine stores execution state in response to a pause control state. ### Claim 3 (depends on 2) The non-transitory computer readable storage medium of claim 2 wherein the execution state includes partition execution state and key execution state. ### Claim 4 (depends on 2) The non-transitory computer readable storage medium of claim 2 wherein the state machine reinitiates execution of a paused operator by invoking the stored execution state. ### Claim 5 (depends on 4) The non-transitory computer readable storage medium of claim 4 wherein the state machine reinitiates execution of the paused operator after redistribution of processing tasks on resources in the distributed computing system. ### Claim 6 (depends on 1) The non-transitory computer readable storage medium of claim 1 wherein the pause control states include a batch service level agreement check state, a partition service level agreement check state and a key service level agreement check state. ### Claim 7 (depends on 1) The non-transitory computer readable storage medium of claim 1 wherein the pause control states include a partition success check state and a key success check state. ### Claim 8 (depends on 1) The non-transitory computer readable storage medium of claim 1 wherein the pause control states include a batch service level agreement check state, a partition service level agreement violation check state, a partition pause state, a key service level agreement violation state and a key pause state. ### Claim 9 (depends on 1) The non-transitory computer readable storage medium of claim 1 wherein the pause control states include a partition replay status state and a key replay status state. ### Claim 10 (depends on 1) The non-transitory computer readable storage medium of claim 1 wherein the pause control states include a partition cleanup state and a key cleanup state. ### Claim 11 (depends on 1) The non-transitory computer readable storage medium of claim 1 wherein the state machine is invoked through method calls associated with an application program interface. ### Claim 12 (depends on 11) The non-transitory computer readable storage medium of claim 11 wherein the application program interface includes method calls to open a data partition, invoke a key in a data partition and close a data partition. ### Claim 13 (depends on 11) The non-transitory computer readable storage medium of claim 11 wherein the application program interface includes method calls to open a key, invoke a subsequent key value and close a key. ### Claim 14 (depends on 11) The non-transitory computer readable storage medium of claim 11 wherein the application program interface includes method calls to open batch data, invoke a subsequent batch of data, and close batch data. ### Claim 15 (depends on 11) The non-transitory computer readable storage medium of claim 11 wherein the application program interface passes data on service level agreement violations. ### Claim 16 (depends on 11) The non-transitory computer readable storage medium of claim 11 wherein the application program interface passes data on input/output exceptions.