Techniques are described herein for distributed data stream programming and processing. The techniques include sending a request indicating one or more regions of a program code to access a stream in a stream pool and to execute on a processing node in a processing nodes pool. The techniques also include accessing the stream defined in the one or more regions of the program code to service the request. Thereafter, the processing node is selected to use for execution of the one or more regions of the program code and the processing node executes one or more instances of the one or more regions of the program code.

A system comprising a gateway for interfacing external data sources with one or more accelerators. The gateway comprises a plurality of virtual gateways, each of which is configured to stream data from the external data sources to one or more associated accelerators. The plurality of virtual gateways are each configured to stream data from external data sources so that the data is received at an associated accelerator in response to a synchronisation point being obtained by a synchronisation zone. Each of the virtual gateways is assigned a virtual ID so that when data is received at the gateway, data can be delivered to the appropriate gateway.

Techniques are provided for analyzing client-side performance data. In one technique, first client performance data and second client performance data is received. The first client performance data was generated by a first client device and indicates a first plurality of processing items that includes a first processing item that is associated with first item performance data. The second client performance data was generated by a second client device and indicates a second plurality of processing items that includes a second processing item that is associated with second item performance data. In response to determining that the first processing item is associated with the second processing item, an aggregate data value is computed based on the first item performance data and the second item performance data.

An intelligent gateway device provided at a premise (home or business) for providing and managing application services associated with use and support of a plurality of digital endpoint devices associated with the premises. The device includes a communications and processing infrastructure integrated with a peer and presence messaging based communications protocol for enabling communications between the device and an external support network and between the device and connected digital endpoint devices. A services framework at the gateway device implements the communications and processing infrastructure for enabling service management, service configuration, and authentication of user of services at the intelligent gateway. The framework provides a storage and execution environment for supporting and executing received service logic modules relating to use, management, and support of the digital endpoint devices. Thus, the gateway device provides a network-based services point of presence for a plurality of digital endpoint devices at the premises.

Techniques are disclosed to calculate a “life script.” The life script may include various behaviors and/or monetary allocations required for a user to meet one or more user-defined objectives. These objectives may indicate various lifestyle habits desired by the user such as where to live, a maximum commuting time to work, how often to travel, etc. Because each of these objectives requires the user to allocate his funds in a certain way and to live in accordance with a particular set of restraints, user information may be collected and aggregated from several sources to generate a user profile indicating the user's financial information, demographics, psychographics, and lifestyle information. The user profile may then be analyzed to calculate a constraint framework that guides the generation of a life script to allow the user to achieve the desired objectives.

Apparatuses, systems, and techniques are directed to automatic coalescing of GPU-initiated network communications. In one method, a communication engine receives, from a shared memory application executing on a first graphics processing unit (GPU), a first communication request assigned to or having a second GPU as a destination to be processed. The communication engine determines that the first communication request satisfies a coalescing criterion and stores the first communication request in association with a group of requests that have a common property. The communication engine coalesces the group of requests into a coalesced request and transports the coalesced request to the second GPU over a network.

A message processing method, device and system for Internet of Things are described. The method includes that: a gateway of the Internet of Things receives one or more operation messages transmitted by a plurality of transmitters for one or more operations of a terminal; and the gateway of the Internet of Things caches and pre-processes the received one or more operation messages in a message queue, and according to a processing result, sends at least one operation message in the message queue to a terminal. By the disclosure, the problems existing in the process of executing interactive operations on the terminal in the related art are solved, the energy consumption generated when the terminal executes the operation messages is saved, and the resource loss of the Internet of Things is reduced.

Methods and systems disclosed herein collect user data in real-time and organize them (e.g., using collaborative filtering) into groups (e.g., clusters). The system then determines statistical distributions of observed real-time intents (e.g., based on actual selections made by users) for each group. The system then merges this distribution with existing model predictions (e.g., a model trained on historical training data) to balance between historical and dynamically updated information.

The invention refers to a system for real-time resource consumption control in a distributed environment and a corresponding method, the system comprising: a multitude of server instances (Sx) having access to shared resources, whereby each request for a shared resource issued by a client application (CA) is handled by one of the server instances (Sx); a global resource consumption counter (G), representing the overall resource consumption of the multitude of server instances (Sx) at a given time; and a multitude of proxy servers (Lx), each proxy server comprising—a receiver module (R) for receiving resource consumption requests issued from a client application (CA), a resource consumption decision module (Dm) for accepting or rejecting a resource consumption request, a queue (Q) for collecting resource consumption requests that have been locally accepted by the respective proxy server (Lx), a local resource consumption counter (L), representing the global resource consumption as seen by the respective proxy server (Lx), said local resource consumption counter (L) being updated every time a resource consumption request is accepted by the decision module (Dm), the updated value being provided in turn as an input to the decision module (Dm), and a synchronization module (S) for synchronizing the global resource consumption counter (G) by interfacing with all other server instances (Sx).

Methods and systems for providing network models and network configurations for communications are described. The method includes establishing, by a device intermediary to a plurality of clients and servers, a first interface on a manager of the device for delivering a network model of the device from the manager of the device to a software defined network (SDN) controller of an SDN. The method includes providing, via the first interface, the network model configured to provide definitions of one or more network layer entities of the device that are configured to provide network layer services. The method includes establishing, a second interface on the manager of the device configured to transmit and receive communications between the device and the SDN controller. The method includes receiving, by the manager via the second interface, network configuration to configure the device to process SDN application requests received from the SDN controller.