摘要:
A method, computer program product, and system for de-centralized stream processing is provided. The method may include providing a plurality of processing nodes in a hierarchical genome having a plurality of levels, wherein each of said processing nodes is 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 within each level of the hierarchical genome. 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.
摘要:
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 also include providing a genome including a hierarchical set of tasks that represent a hierarchical functional decomposition of one or more problem scenarios. The method may further include identifying, at each of the processing nodes, one or more tasks for a first genome level. The method may additionally include differentiating, at one or more of the plurality of processing nodes, into one or more tasks, based upon, at least in part, the first genome level. The method may further include grouping a plurality of the processing nodes together to achieve a power level. The method may also include activating a second genome level once the power level has been reached. The method may further include repeating until one or more of the nodes differentiates into a further genome level.
摘要:
A method, computer program product, and system for de-centralized stream processing is provided. The method may include providing a plurality of processing nodes in a hierarchical genome having a plurality of levels, wherein each of said processing nodes is 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 within each level of the hierarchical genome. 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.
摘要:
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 adding one or more new processing nodes to the computing system. The method may also include determining a source node based upon, at least in part, an activation level being above or below a particular threshold. The method may additionally include, for each of the one or more added processing nodes, automatically determining an appropriate role, based upon, at least in part, a neighboring processing node.
摘要:
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 also include providing a genome including a hierarchical set of tasks that represent a hierarchical functional decomposition of one or more problem scenarios. The method may further include identifying, at each of the processing nodes, one or more tasks for a first genome level. The method may additionally include differentiating, at one or more of the plurality of processing nodes, into one or more tasks, based upon, at least in part, the first genome level. The method may further include grouping a plurality of the processing nodes together to achieve a power level. The method may also include activating a second genome level once the power level has been reached. The method may further include repeating until one or more of the nodes differentiates into a further genome level.
摘要:
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.
摘要:
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.
摘要:
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 adding one or more new processing nodes to the computing system. The method may also include determining a source node based upon, at least in part, an activation level being above or below a particular threshold. The method may additionally include, for each of the one or more added processing nodes, automatically determining an appropriate role, based upon, at least in part, a neighboring processing node.
摘要:
Embodiments of the present invention address deficiencies of the art in respect to structured content storage and provide a novel and non-obvious method, system and computer program product for managing structured content stored in a BLOB. In an embodiment of the invention, a performance optimized structured content management system can include a content repository, a content manager configured to provide access to structured content in the content repository and multiple different performance optimized containers disposed in the content repository. Each of the containers can store a portion of the structured content, and each of the containers can include a flattened form of original structured content in a primary binary large object (BLOB) and a parsed form of the original structured content in a secondary BLOB, the parsed form of the original structured content in the secondary BLOB indexing the flattened form of the original structured content in the primary BLOB.
摘要:
Embodiments of the present invention address deficiencies of the art in respect to virtual world navigation and provide a method, system and computer program product for applying temporal rankings to elements in a virtual world. In an embodiment of the invention, a method for temporally ranking locations in a virtual world can be provided. The method can include timing a duration of visit for different locations in a virtual world, computing a temporal score for the different locations, and displaying a ranking of the locations by temporal score. For instance, computing a temporal score for the different locations can include computing a sum of durations for each of the different locations, or computing an average of durations for each of the different locations, to name two examples. Optionally, computing a temporal score for the different locations also can include filtering the durations according to a date or time range.