System and method for stream processing utilizing totipotent morphogenic stem cells
AssigneeInternational Business Machines Corporation
InventorsKenneth Sabir, David Lowe
Life of this patent
Estimating the term…
Abstract
A method, computer program product, and system for de-centralized stream processing is provided. The method may include providing a plurality of processing nodes each of said processing nodes configured to transmit and receive a stream of data. The method may further include restricting a subset of the plurality of processing nodes from differentiating into a role. The method may also include identifying a failure at one of the processing nodes and replacing the failed node with one of the processing nodes from the restricted subset.
Claims14
A computer-implemented method for de-centralized stream processing, the method comprising:
- providing a plurality of processing nodes each of said processing nodes configured to transmit and receive a stream of data;
- restricting a subset of the plurality of processing nodes from differentiating into a role such that the plurality of processing nodes of the restricted subset are independent from role morphogens;
- identifying a failure at one of the processing nodes;
- replacing the failed node with one of the processing nodes from the restricted subset;
- and
- adding a node to the restricted subset after the failed node has been replaced, wherein the added node is an under-utilized node with a light load.
A computer program product residing on a computer readable storage medium having a plurality of instructions for de-centralized stream processing, which, when executed by a processor, cause the processor to perform operations comprising:
- providing a plurality of processing nodes each of said processing nodes configured to transmit and receive a stream of data;
- restricting a subset of the plurality of processing nodes from differentiating into a role such that the plurality of processing nodes of the restricted subset are independent from role morphogens;
- identifying a failure at one of the processing nodes;
- replacing the failed node with one of the processing nodes from the restricted subset;
- and
- adding a node to the restricted subset after the failed node has been replaced, wherein the added node is an under-utilized node with a light load.
A computing system for de-centralized stream processing comprising:
- at least one processor;
- at least one memory architecture coupled with the at least one processor;
- a first software module executable by the at least one processor and the at least one memory architecture, wherein the first software module is configured to provide a plurality of processing nodes each of said processing nodes configured to transmit and receive a stream of data;
- a second software module executable by the at least one processor and the at least one memory architecture, wherein the second software module is configured to restrict a subset of the plurality of processing nodes from differentiating into a role such that the plurality of processing nodes of the restricted subset are independent from role morphogens;
- a third software module executable by the at least one processor and the at least one memory architecture, wherein the third software module is configured to identify a failure at one of the processing nodes;
- a fourth software module executable by the at least one processor and the at least one memory architecture, wherein the fourth software module is configured to replace the failed node with one of the processing nodes from the restricted subset;
- and
- a fifth software module executable by the at least one processor and the at least one memory architecture, wherein the fifth software module is configured to add a node to the restricted subset after the failed node has been replaced, wherein the added node is an under-utilized node with a light load.
Dependencies are inferred from the claim text.