A method, computer-readable medium, and device for processing a stream of records with a guarantee that each record is accounted for exactly once are disclosed. A method may receive, via a first operator, a data stream having a plurality of records, the plurality of records provided by a plurality of first data sources; allocate the data stream to a plurality of shards of the first operator; process the plurality of records by each shard of the plurality of shards to generate a first output stream, where each shard being implemented with at least two replicas; and output the first output stream to a third operator or a subscriber.

The system described herein can automatically match, link, or otherwise associate record objects with one or more node profiles. For a record object that is eligible or qualifies to be matched with one or more node profiles, the system can selectively apply rules to match the record object to a subset of the one or more node profiles based on values of fields extracted from the record object and values of the node profiles. The system can then store an association between the record object and the subset of the one or more node profiles.

A method, computer system, and a computer program product for managing asset placement with respect to a distributed computing environment having a set of hosts is provided. The present invention may include detecting a set of host computing resource requirement data for an asset, wherein the distributed computing environment includes a stream computing environment and the asset includes a rookie asset in the stream computing environment. The present invention may include identifying a set of computing resource profile data for a set of hosts in the distributed computing environment. The present invention may include determining, by comparing the set of host computing resource requirement data for the asset and the set of computing resource profile data for the set of hosts, an asset placement arrangement. The present invention may include establishing, based on the asset placement arrangement, the asset in the distributed computing environment.

A method and apparatus are described for supporting a two-stage device-to-device (D2D) discovery using a D2D interworking function (IWF). A D2D IWF component may be configured to perform mapping between an application running on an application server and a third generation partnership project (3GPP) network, and provide a set of application programming interfaces (APIs) to allow discovery to be provided as a service to D2D applications. An application identifier may be mapped to a 3GPP identifier. Further, a method and apparatus are described for performing client-server discovery. A first wireless transmit/receive unit (WTRU) may be configured for a listen-only operation, and a second WTRU may be configured to transmit beacons. The first and second WTRUs may perform a radio access network (RAN) discovery procedure at an access stratum (AS) layer. A method and apparatus for performing charging for D2D service using a D2D IWF are also described.

Systems, graphical user interfaces, and methods are provided to optimize bandwidth usage associated with a local network. As part of the bandwidth optimization techniques, a network regulation entity may maintain a plurality of usage statistics for a plurality of electronic devices. These usage statistics may be presented by an electronic device as part of a usage summary interface. In addition to displaying the usage statistics, the usage summary interface may enable a user to modify how the network regulation entity regulates traffic. Accordingly, the network regulation entity may update an access profile in accordance with the modification. Subsequently, the traffic received from the electronic device is processed based on the user-indicated modification. Thus, compliance with network neutrality principles may be maintained.

The systems and methods described herein can maintain time series of data points. The system can access at least one of a plurality of electronic activities transmitted or received via electronic accounts of one or more data source providers or a plurality of record objects of one or more systems of record of the one or more data source providers; maintain an association between each electronic activity or record object and a timestamp corresponding to when the electronic activity was sent or received by an or when the record object was last updated; maintain a plurality of node profiles; and generate, for a particular time, a confidence score of a value of a field-value pair of a node profile only using the data of the plurality of electronic activities or the plurality of record objects that correspond to the value and have a corresponding timestamp prior to or contemporaneous with the particular time.

Methods, systems, and storage media for identifying a sequence of events and participants for record objects are disclosed. Exemplary implementations may: access record objects of a system of record; identify a subset of record objects associated with a group entity and having a first record object status; identify one or more electronic activities linked to the record objects; determine an event-participant pattern based on the electronic activities linked to the record object; identify electronic activities linked with a second record object; determine that a first event is performed by the a participant type and a second event is not yet performed by a second participant type; generate a content item identifying an action to trigger a performance of the second event; and transmit the content item to a device of a participant of at least one electronic activity linked with the second record object.

The systems and methods described herein can use multiple fields with dynamically determined priorities based on field values for node resolution. The system can generate activity field-value pairs including an activity value associated with an activity field from an electronic activity. The system can determine a frequency score based on a first count of node field-value pairs that match the activity value. The system can assign a weight to the activity value based on the frequency score. The system can generate a match score of a candidate node profile indicating a likelihood that the electronic activity is transmitted or received by an account corresponding to the candidate node profile. The system can store an association between the electronic activity and the node profile selected based on the match score.

The present disclosure relates to methods, systems, and storage media for classifying phone numbers based on node profile data. Exemplary embodiments for classifying phone numbers based on node profile data may maintain a plurality of node profiles and generate a plurality of activity field-value pairs from an electronic activity. Each activity field-value pair of the plurality of activity field-value pairs corresponding to at least one participant of the electronic activity. Exemplary embodiments may further parse the electronic activity to identify a string corresponding to an electronic activity phone number, determine a type of phone number to which the electronic activity phone number corresponds using a data structure, identify a node profile of the plurality of node profiles corresponding to a participant of the electronic activity to which the electronic activity phone number corresponds, and update the identified node profile by the determined phone number type.

Systems and methods enable distribution of data transfer capacity in a WWAN between mobile devices. The data transfer capacity is given by a data plan for the respective mobile device. The systems and methods register first and second mobile devices with a transaction service as acquirers and providers, respectively, of data transfer capacity. The systems and methods detect when a first mobile device indicates a desire to acquire data transfer capacity, identify one or more second mobile devices that are located within reach for short-range communication with the first mobile device, and connect the first mobile device by short-range communication to one of the second mobile devices such that the first mobile device is tethered to the WWAN by this second mobile device. The systems and methods may also distribute authentication data to enable the first mobile device to be authenticated by the second mobile device.