The present invention relates to a system (100) and method with a fast distributed data processing engine (105) for fast and scalable data-intensive computation comprising a data model (110) defining an addressable collection of a message space, addressing a message space constellation (115) and the message space with one or more coordinates, updating the message space and the program state with the message following a consistency model, defining an attribute for an area within the message space and running a task in the message space constellation (115). In particular, each task accesses a part of the message space in a subset of the message space constellation (115).

Systems and method are provided for receiving, at a virtualized management operation engine (VMOE) of a distributed system, a management task request from a client for one or more services. The management task request may be to an orchestrator of a first application server of one or more application servers of the distributed system. The first application server having the orchestrator may determine whether the management task request is valid. The first application server having the orchestrator may generate a request message based on the valid management task request. A message bus may broadcast the generated request message to one or more agents of the one or more application servers of the distributed system. The one or more agents may execute an operation based on the request message when the request message is intended for the one or more agents.

A CPU is allocated in view of service requirements of a virtual machine. An IaaS platform generates a virtual CPU and a virtual machine on a physical CPU of a compute node and allocates the virtual CPU to the virtual machine. This IaaS platform includes a resource allocation determination unit 32 configured to generate an instruction to cause the virtual CPU allocated to the virtual machine to occupy a physical CPU of a designated compute node in a case where load to be imposed on a process which is to run on the virtual machine is higher than a predetermined value, and generate an instruction to pin the virtual CPU at the physical CPU in a case where latency requirements of the process are stricter than a predetermined value, and generate an instruction not to pin the virtual CPU at the physical CPU in a case where the latency requirements of the process are laxer than a predetermined value, and a virtual machine generation management unit 34 configured to generate a new virtual machine on the physical CPU of the compute node in response to the instruction from the resource allocation determination unit.

Methods, apparatus, systems and machine-readable storage media of an edge computing device which is enabled to access and select the use of local or remote acceleration resources for edge computing processing is disclosed. In an example, an edge computing device obtains first telemetry information that indicates availability of local acceleration circuitry to execute a function, and obtains second telemetry that indicates availability of a remote acceleration function to execute the function. An estimated time (and cost or other identifiable or estimateable considerations) to execute the function at the respective location is identified. The use of the local acceleration circuitry or the remote acceleration resource is selected based on the estimated time and other appropriate factors in relation to a service level agreement.

An approach to optimizing utilization of virtual agents within a virtual agent system. The approach may include monitoring the processing loads of virtual agents and identifying highly utilized virtual agents. The approach may also include configuring a pathway which directs a user query to the identified highly utilized virtual agent and allowing the highly utilized virtual agent to respond to the user query if the highly utilized virtual agent is capable of generating a satisfactory response. Additionally, the approach may include sending the user query to one or more other virtual agents if the highly utilized virtual agent is unable to generate a response above a confidence threshold.

Peer-to-peer transfer of compute function state in an edge computing ecosystem is provided. An availability score corresponding to a mobile computing device is received. It is determined whether the availability score is less than an availability score threshold. In response to determining that the availability score is less than the availability score threshold, departure coordinates of the mobile computing device from the edge computing ecosystem and departure time are determined. At least one peer mobile computing device is identified having a corresponding availability score greater than the availability score threshold, a corresponding security profile that at least matches a security profile of the mobile computing device, and a corresponding compute power capability that at least matches a compute power capability of the mobile computing device. A compute function state of the mobile computing device is transferred to the at least one peer mobile computing device.

A method includes: interacting, by a first device, with a user through an application in a data collection range; after determining that the user is not located in the data collection range, determining, by the first device, that the user is located in a data collection range of a second device in a network; and sending, by the first device, to-be-migrated data to the second device, so that the second device continues to interact with the user based on the to-be-migrated data. The second device supports the application, the to-be-migrated data includes information about the application and progress information, and the progress information indicates progress of interaction between the first device and the user.

In a network of mobile agents, data integrity can be improved by providing an agent server that can migrate between devices operating in the region of interest (ROI). The agent server distributes agent clients onto devices in the ROI and provides agent server services to the agent clients, including receiving and storing data from the agents. When the agent server device is to leave the ROI, the agent server can migrate to any device executing an agent client and continue to provide the agent server services, including data collection and aggregation, from the device to which the agent server has migrated.

A method includes collecting, by one or more processors of a computer system, digestive capabilities for Input Output Queues (IOQs) of infrastructure components in a hybrid cloud infrastructure, and allocating, by the one or more processors of the computer system, nonvolatile memory express (NVMe) storage cloud resources for the hybrid cloud infrastructure based on the collected digestive capabilities for IOQs of the infrastructure components.

In a network of mobile agents, data integrity can be improved by providing an agent server that can migrate between devices operating in the region of interest (ROI). The agent server distributes agent clients onto devices in the ROI and provides agent server services to the agent clients, including receiving and storing data from the agents. When the agent server device is to leave the ROI, the agent server can migrate to any device executing an agent client and continue to provide the agent server services, including data collection and aggregation, from the device to which the agent server has migrated.